GitHub user jeff-cook created 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. 

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