diff --git a/ingestion/src/metadata/ingestion/source/pipeline/airbyte.py b/ingestion/src/metadata/ingestion/source/pipeline/airbyte.py
index 1f72c0fccb9..44b7da85a41 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/airbyte.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/airbyte.py
@@ -156,7 +156,7 @@ class AirbyteSource(Source[CreatePipelineRequest]):
         Method to get task & pipeline status
         """
         for job in self.client.list_jobs(connection.get("connectionId")):
-            if not job or job.get("attempts"):
+            if not job or not job.get("attempts"):
                 continue
             for attempt in job["attempts"]:
                 task_status = [