chore: Added basic integration tests for task enqueue and delete

Author: jonathanedey

CONTRIBUTING.md

@@ -252,6 +252,17 @@ to ensure that exported user records contain the password hashes of the user acc
    3. Click **ADD ANOTHER ROLE** and choose **Firebase Authentication Admin**.
    4. Click **SAVE**.
 
+9. Enable Cloud Tasks:
+   1. Search for and enable **Cloud Run**.
+   2. Search for and enable **Cloud Tasks**.
+   3. Go to [Google Cloud console | IAM & admin](https://console.cloud.google.com/iam-admin)
+   and make sure your Firebase project is selected.
+   4. Ensure your service account has the following required roles:
+      * **Cloud Tasks Enqueuer** - `cloudtasks.taskEnqueuer`
+      * **Cloud Tasks Task Deleter** - `cloudtasks.taskDeleter`
+      * **Cloud Run Invoker** - `run.invoker`
+      * **Service Account User** - `iam.serviceAccountUser`
+
 
 Now you can invoke the integration test suite as follows:
 

integration/test_functions.py

@@ -21,6 +21,8 @@
 from integration import conftest
 
 
+_DEFAULT_DATA = {'data': {'city': 'Seattle'}}
+
 @pytest.fixture(scope='module')
 def app(request):
     cred, _ = conftest.integration_conf(request)
@@ -54,3 +56,21 @@ def test_task_queue_app(self, task_queue_params, app):
         assert queue is not None
         assert callable(queue.enqueue)
         assert callable(queue.delete)
+    
+    def test_task_enqueue(self, app):
+        queue = functions.task_queue('testTaskQueue', app=app)
+        task_id = queue.enqueue(_DEFAULT_DATA)
+        assert task_id is not None
+    
+    def test_task_delete(self, app):
+        # Skip this test against the emulator since tasks can't be delayed there to verify deletion
+        # See: https://github.com/firebase/firebase-tools/issues/8254
+        task_options = functions.TaskOptions(schedule_delay_seconds=60)
+        queue = functions.task_queue('testTaskQueue', app=app)
+        task_id = queue.enqueue(_DEFAULT_DATA, task_options)
+        assert task_id is not None
+        queue.delete(task_id)
+        # We don't have a way to check the contents of the queue so we check that the deleted
+        # task is not found using the delete method again.
+        with pytest.raises(firebase_admin.exceptions.NotFoundError):
+            queue.delete(task_id)