Skip to content

Commit

Permalink
minor change; schema change should always be there since people come …
Browse files Browse the repository at this point in the history
…from pending actions tab
  • Loading branch information
Ishankoradia committed Oct 9, 2024
1 parent 9512fbc commit c8f6be9
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions ddpui/ddpairbyte/airbytehelpers.py
Original file line number Diff line number Diff line change
Expand Up @@ -1312,9 +1312,12 @@ def schedule_update_connection_schema(
job.save()

# update the schema change with the scheduled job
OrgSchemaChange.objects.get_or_create(
org=orguser.org, connection_id=connection_id, defaults={"schedule_job": job}
)
schema_change = OrgSchemaChange.objects.filter(
connection_id=connection_id, org=orguser.org
).first()
if schema_change:
schema_change.schedule_job = job
schema_change.save()

for tasklock in locks:
tasklock.flow_run_id = res["flow_run_id"]
Expand Down

0 comments on commit c8f6be9

Please sign in to comment.