Move import to make PythonOperator working on Windows

apache · Jun 25, 2024 · 0a7c454 · 0a7c454
1 parent 5f2da71
commit 0a7c454
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/operators/python.py b/airflow/operators/python.py
@@ -17,7 +17,6 @@
 # under the License.
 from __future__ import annotations
 
-import fcntl
 import importlib
 import inspect
 import json
@@ -790,6 +789,8 @@ def _ensure_venv_cache_exists(self, venv_cache_path: Path) -> Path:
         venv_path.parent.mkdir(parents=True, exist_ok=True)
         with open(f"{venv_path}.lock", "w") as f:
             # Ensure that cache is not build by parallel workers
+            import fcntl
+
             fcntl.flock(f, fcntl.LOCK_EX)
 
             hash_marker = venv_path / "install_complete_marker.json"