hard20 pts · first answer countsairflowdeferrable-operators

Lost variable after a task resumes

A custom deferrable operator sets self.job_id = start_job() in execute(), then defers. When the trigger fires, the resume method fails because job_id is missing. Why?

A.Triggers delete all instance attributes on purposeB.self is read-only after defer() is calledC.The resume method runs before execute finishesD.The task resumes in a fresh process; pass job_id via kwargs

Discussion 0

Join free to post in the discussion.

Lost variable after a task resumes

Discussion 0

Related questions