Commit ee47959e authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

overwrite dag

parent e6fe1037
...@@ -187,7 +187,10 @@ class BaseDAG: ...@@ -187,7 +187,10 @@ class BaseDAG:
# update values # update values
dag_run = override_common_keys(dag_run, kwargs) dag_run = override_common_keys(dag_run, kwargs)
# set hash # set hash
dag_run = override_common_keys(dag_run, {"dag_run": self.generate_sha1()}) dag_run = override_common_keys(
dag_run,
{"dag": self.dag, "dag_run": self.generate_sha1()},
)
return dag_run return dag_run
@staticmethod @staticmethod
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment