xBis7 commented on code in PR #61812:
URL: https://github.com/apache/airflow/pull/61812#discussion_r2814094483
##########
providers/edge3/src/airflow/providers/edge3/worker_api/routes/jobs.py:
##########
@@ -87,8 +87,6 @@ def fetch(
# Edge worker does not backport emitted Airflow metrics, so export some
metrics
tags = {"dag_id": job.dag_id, "task_id": job.task_id, "queue": job.queue}
try:
- from airflow.sdk._shared.observability.metrics.dual_stats_manager
import DualStatsManager
-
DualStatsManager.incr("edge_worker.ti.start", tags=tags)
Review Comment:
If I understand correctly, when setting
```
"apache-airflow-providers-common-compat>=1.13.0", # use next version
```
then it means that the current version of the `edge3` provider will be
tested with the next available version of the `common-compat` to avoid updating
both at the same time.
The CI failure doesn't have to do with that because it's checking against
the `airflow-core` which is also shipped with a snapshot of the `shared`
package.
It's running the latest `edge3` with the latest `common-compat` against
airflow 2.11 and trying to access `shared` code which was added in airflow
3.1.X.
--
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]
