Skip to content

Commit

Permalink
Merge pull request #18 from tuanavu/development
Browse files Browse the repository at this point in the history
Update example_variables dag to use the default variable
  • Loading branch information
tuanavu committed Mar 29, 2019
2 parents 1609792 + 574b176 commit 0950352
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions examples/intro-example/dags/example_variables.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,21 +19,21 @@


# Config variables
## Common
# var1 = "value1"
# var2 = [1, 2, 3]
# var3 = {'k': 'value3'}
# Common
var1 = "value1"
var2 = [1, 2, 3]
var3 = {'k': 'value3'}

## 3 DB connections called
# var1 = Variable.get("var1")
# var2 = Variable.get("var2")
# var3 = Variable.get("var3")

## Recommended way
dag_config = Variable.get("example_variables_config", deserialize_json=True)
var1 = dag_config["var1"]
var2 = dag_config["var2"]
var3 = dag_config["var3"]
# ## Recommended way
# dag_config = Variable.get("example_variables_config", deserialize_json=True)
# var1 = dag_config["var1"]
# var2 = dag_config["var2"]
# var3 = dag_config["var3"]

start = DummyOperator(
task_id="start",
Expand Down

0 comments on commit 0950352

Please sign in to comment.