From b7b52f57664168ed6f7bccc55a3fdcdc73bd8bc8 Mon Sep 17 00:00:00 2001
From: Venkat <venkatajagannath.yellapragada@astronomer.io>
Date: Mon, 10 Jun 2024 18:15:08 -0400
Subject: [PATCH] event updated

---
 tests/dags/utils.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/tests/dags/utils.py b/tests/dags/utils.py
index a441b36..42ba951 100644
--- 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))