blag commented on code in PR #25419:
URL: https://github.com/apache/airflow/pull/25419#discussion_r946218615
##########
airflow/models/dataset.py:
##########
@@ -203,6 +206,44 @@ def __repr__(self):
return f"{self.__class__.__name__}({', '.join(args)})"
+class DatasetEventManager(LoggingMixin):
+ """
+ A pluggable class that manages operations for dataset events.
+
+ The intent is to have one place to handle all DatasetEvent-related
operations, so different
+ Airflow deployments can use plugins that broadcast dataset events to each
other.
+ """
+
+ def register_dataset_change(
+ self, *, task_instance=None, dataset=None, session: Session =
NEW_SESSION
Review Comment:
I like `extra` better, since we're closer to the DB here than we are to an
HTTP request.
--
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]
