event updated

astronomer · Jun 10, 2024 · b7b52f5 · b7b52f5
1 parent 1039e8e
commit b7b52f5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/tests/dags/utils.py b/tests/dags/utils.py
@@ -84,7 +84,10 @@ def test_dag(
             for ti in deferred_tis:
                 ti.task = tasks[ti.task_id]
                 try:
-                    ti.task.execute_complete(context={}, event={"status": "success"})
+                    ti.task.execute_complete(context={}, event={"status": "success",
+                                                                "job_id":"anyscale_job_integration_test",
+                                                                "service_name": "anyscale_svc_integration_test",
+                                                                "message":"Integration succeeded"})
                 except Exception as e:
                     ti.state = State.FAILED
                     ti.log.exception("Error while resuming deferred task %s: %s", ti.task_id, str(e))