From 5066b1e740bc6edf49b3d7cba4fc49f61d6e38b1 Mon Sep 17 00:00:00 2001
From: Mayur Singal <39544459+ulixius9@users.noreply.github.com>
Date: Thu, 30 Jun 2022 08:21:08 +0530
Subject: [PATCH] Airbyte Minor Fix (#5758)

---
 ingestion/src/metadata/ingestion/source/pipeline/airbyte.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 = [