potiuk commented on code in PR #30308:
URL: https://github.com/apache/airflow/pull/30308#discussion_r1162453467
##########
airflow/jobs/job.py:
##########
@@ -292,3 +281,51 @@ def most_recent_job(job_type: str, session: Session =
NEW_SESSION) -> Job | None
)
.first()
)
+
+
+@provide_session
+def prepare_for_execution(job: Job | JobPydantic, session: Session =
NEW_SESSION):
Review Comment:
Not **yet** but part of the change is to make it possible to do so - the
thing is that once we add @internal_api method to those methods, they willl be
run with JobPydantic as parameters. I try to make it a bit clearer in a fixup I
am just about to complete testing of (and with a sequence diagram showing what
is going to happen in both cases to explain why I am doing this). Hold on a bit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
