GitHub user kishumodi created a discussion: Unable to achieve deferred state 
after upgrading airflow to 3.0.2 from 2.10.4

Earlier I was using airflow 2.10.4, 
I was using AwaitMessageTriggerFunctionSensor to consume messages from kafka, 
where my task was in deferred state until a new message is consumed.

After I upgraded airflow version to 3.0.2, I am unable to achieve deferred 
state. It is always in running/queued state. I am unable to achieve deferred 
state.
Please help me with it.
Also when I checked triggerer logs,  I am always getting "0 triggers currently 
running".
Please help me proceed ahead.

GitHub link: https://github.com/apache/airflow/discussions/55358

----
This is an automatically sent email for comm...@airflow.apache.org.
To unsubscribe, please send an email to: commits-unsubscr...@airflow.apache.org

Reply via email to