diff --git a/airflow/models.py b/airflow/models.py index a1b17ac6e301d..d628057c00a07 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -859,6 +859,7 @@ def set_state(self, state, session): self.start_date = datetime.now() self.end_date = datetime.now() session.merge(self) + session.commit() def is_queueable( self, @@ -1097,7 +1098,6 @@ def are_dependencies_met( session=session, successes=successes, skipped=skipped, failed=failed, upstream_failed=upstream_failed, done=done, flag_upstream_failed=flag_upstream_failed) - session.commit() if verbose and not satisfied: logging.warning("Trigger rule `{}` not satisfied".format(task.trigger_rule)) return satisfied