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

fixed dag_run hash

parent cd58ea9d
...@@ -184,6 +184,8 @@ class BaseDAG: ...@@ -184,6 +184,8 @@ class BaseDAG:
dag_run = self.dag_run_template.copy() dag_run = self.dag_run_template.copy()
# update values # update values
dag_run = override_common_keys(dag_run, kwargs) dag_run = override_common_keys(dag_run, kwargs)
# set hash
dag_run = override_common_keys(dag_run, {"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