amoghrajesh commented on code in PR #68438:
URL: https://github.com/apache/airflow/pull/68438#discussion_r3407840294
##########
airflow-core/src/airflow/jobs/scheduler_job_runner.py:
##########
@@ -3545,7 +3545,7 @@ def _update_asset_orphanage(self, *, session: Session =
NEW_SESSION) -> None:
self._orphan_unreferenced_assets(orphan_query, session=session)
self._activate_referenced_assets(activate_query, session=session)
- self._cleanup_orphaned_asset_store(session=session)
+ self._cleanup_orphaned_asset_state_store(session=session)
Review Comment:
No need for it. That's because:
- task state store rows are tied to dag_run_id and clean up immediately
when a dagrun is gone
- there's a cleanup utility provided for this `airflow state-store
cleanup-task-state-store` whcih handles expiry-based cleanup for long-lived rows
--
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]
