Skip to content

Commit cb43352

Browse files
Fix dag reserialize not calling bundle initialize (apache#46355)
Some bundle types, like git, require that `initialize` is called before you can call other methods, like `get_current_version`. This was missed when introducing `initialize` though.
1 parent 0c41b5c commit cb43352

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

airflow/cli/commands/remote_commands/dag_command.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -546,10 +546,12 @@ def dag_reserialize(args, session: Session = NEW_SESSION) -> None:
546546
bundle = manager.get_bundle(args.bundle_name)
547547
if not bundle:
548548
raise SystemExit(f"Bundle {args.bundle_name} not found")
549+
bundle.initialize()
549550
dag_bag = DagBag(bundle.path, include_examples=False)
550551
dag_bag.sync_to_db(bundle.name, bundle_version=bundle.get_current_version(), session=session)
551552
else:
552553
bundles = manager.get_all_dag_bundles()
553554
for bundle in bundles:
555+
bundle.initialize()
554556
dag_bag = DagBag(bundle.path, include_examples=False)
555557
dag_bag.sync_to_db(bundle.name, bundle_version=bundle.get_current_version(), session=session)

0 commit comments

Comments
 (0)