ferruzzi commented on code in PR #62645:
URL: https://github.com/apache/airflow/pull/62645#discussion_r3066642685
##########
airflow-core/src/airflow/executors/workloads/base.py:
##########
@@ -83,3 +85,71 @@ class BaseDagBundleWorkload(BaseWorkloadSchema, ABC):
dag_rel_path: os.PathLike[str] # Filepath where the DAG can be found
(likely prefixed with `DAG_FOLDER/`)
bundle_info: BundleInfo
log_path: str | None # Rendered relative log filename template the task
logs should be written to.
+
+ @property
+ @abstractmethod
+ def key(self) -> Hashable:
+ """
+ Return the unique key identifying this workload instance.
+
+ Used by executors for tracking queued/running workloads and reporting
results.
+ Must be a hashable value suitable for use in sets and as dict keys.
+
+ Must be implemented by subclasses.
+ """
Review Comment:
Good catch, I'll fix that.
--
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]
