Skip to content

Commit cbcef4a

Browse files
committed
refactor: enhance import processing in generate_dag_python_imports method
1 parent 847051e commit cbcef4a

File tree

1 file changed

+18
-3
lines changed

1 file changed

+18
-3
lines changed

dagify/converter/uf.py

Lines changed: 18 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -206,9 +206,24 @@ def calculate_dag_python_imports(self, dag_divider_key="", dag_divider_value="")
206206

207207
# Process to Pythonic Statements
208208
for package, imports_list in dag_imps.items():
209-
imports = ', '.join(imports_list)
210-
python_imports.append(f"from {package} import {imports}")
211-
209+
from_imports = []
210+
import_imports = []
211+
for imp in imports_list:
212+
# If the import uses 'as' (alias), treat as a direct import
213+
if " as " in imp:
214+
import_imports.append(imp)
215+
# If the package name does not contain a dot, treat as a direct import
216+
elif "." not in package:
217+
import_imports.append(imp)
218+
imports_str = ', '.join(from_imports)
219+
python_imports.append(f"from {package} import {imports_str}")
220+
221+
if from_imports:
222+
imports = ', '.join(from_imports)
223+
python_imports.append(f"from {package} import {imports}")
224+
for imp in import_imports:
225+
python_imports.append(f"import {imp}")
226+
212227
# Set the Python Imports for the DAG
213228
return python_imports
214229

0 commit comments

Comments
 (0)