Skip to content

Comments

Adding an example to illustrate the TriggerDagRunOperator#1043

Merged
r39132 merged 4 commits intoapache:masterfrom
r39132:master
Feb 20, 2016
Merged

Adding an example to illustrate the TriggerDagRunOperator#1043
r39132 merged 4 commits intoapache:masterfrom
r39132:master

Conversation

@r39132
Copy link
Contributor

@r39132 r39132 commented Feb 19, 2016

Addressing #1001 by adding examples

r39132 added a commit that referenced this pull request Feb 20, 2016
Adding an example to illustrate the TriggerDagRunOperator
@r39132 r39132 merged commit f6adf37 into apache:master Feb 20, 2016
def run_this_func(ds, **kwargs):
print( "Remotely received value of {} for key=message".format(kwargs['dag_run'].conf['message']))

run_this = PythonOperator(
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

don't you need import PythonOperator?



# Define the single task in this controller example DAG
trigger = TriggerDagRunOperator(task_id='test_trigger_dagrun',
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

need import TriggerDagRunOperator

Copy link

@fzhcary fzhcary left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

need add imports

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants