uranusjr commented on issue #33272: URL: https://github.com/apache/airflow/issues/33272#issuecomment-3489699281
In Airflow 3, consumer dag runs would now all have their logical date set to *None*. The intention is you are not supposed to use the dag runs to indicate the consumer dag’s *state*. Instead, this *state* would be represented by a new concept called [asset partitions](https://cwiki.apache.org/confluence/display/AIRFLOW/AIP-76%2BAsset%2BPartitions). In its simplest form, each partition (of the consumer dag) can be fulfilled by a consumer dag run triggered by an asset event. If a partition is not fulfilled correctly, you can create another consumer dag run to re-fulfill it without destroying history (of the previous dag run). We feel this is a more desirable way to achieve the same end goal. -- 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]
