GitHub user jeff-cook edited a discussion: dag-processor does not show a new 
version when an import changes

We use git sync and KubernetesPodOperator.

We have created a function that will return the `KubernetesPodOperator` or 
`DockerOperator` this allows local development to run the DAG locally for 
testing and it will switch the DockerOperator.

This function is in it's own file so it can be imported for every dag.

I have noticed that if there is only a change in the function Airflow or dag 
processor doesn't see that as a change to the dag itself. Which means there is 
not a new version imported and this means changes do not get tested or used. 

It does however use the new code on dag run. It's very hard to identify if/when 
it changed. 

Is this expected behavior? Is there a work around, other then modifying every 
dag file every time the function is updated? 

We are using `apache/airflow:3.0.2` via the current helm chart version `1.18.0`.



GitHub link: https://github.com/apache/airflow/discussions/60900

----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]

Reply via email to