Airbyte Minor Fix (#5758)

This commit is contained in:
Mayur Singal 2022-06-30 08:21:08 +05:30 committed by GitHub
parent df704fb566
commit 5066b1e740
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -156,7 +156,7 @@ class AirbyteSource(Source[CreatePipelineRequest]):
Method to get task & pipeline status Method to get task & pipeline status
""" """
for job in self.client.list_jobs(connection.get("connectionId")): 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 continue
for attempt in job["attempts"]: for attempt in job["attempts"]:
task_status = [ task_status = [