Update Dag for openrc path

This commit is contained in:
eanylin 2017-06-20 01:42:39 +00:00
parent eab86b6a87
commit 32ac66ad16

View File

@ -40,31 +40,34 @@ t1 = BashOperator(
bash_command='date', bash_command='date',
dag=dag) dag=dag)
## Note that the openrc.sh file needs to be placed on a volume that can be
## accessed by the containers
# openstack endpoint list # openstack endpoint list
t2 = OpenStackOperator( t2 = OpenStackOperator(
task_id='endpoint_list_task', task_id='endpoint_list_task',
openrc_file='/home/ubuntu/airflow/openrc.sh', openrc_file='/usr/local/airflow/dags/openrc.sh',
openstack_command='openstack endpoint list', openstack_command='openstack endpoint list',
dag=dag) dag=dag)
# openstack service list # openstack service list
t3 = OpenStackOperator( t3 = OpenStackOperator(
task_id='service_list_task', task_id='service_list_task',
openrc_file='/home/ubuntu/airflow/openrc.sh', openrc_file='/usr/local/airflow/dags/openrc.sh',
openstack_command='openstack service list', openstack_command='openstack service list',
dag=dag) dag=dag)
# openstack server list # openstack server list
t4 = OpenStackOperator( t4 = OpenStackOperator(
task_id='server_list_task', task_id='server_list_task',
openrc_file='/home/ubuntu/airflow/openrc.sh', openrc_file='/usr/local/airflow/dags/openrc.sh',
openstack_command='openstack server list', openstack_command='openstack server list',
dag=dag) dag=dag)
# openstack network list # openstack network list
t5 = OpenStackOperator( t5 = OpenStackOperator(
task_id='network_list_task', task_id='network_list_task',
openrc_file='/home/ubuntu/airflow/openrc.sh', openrc_file='/usr/local/airflow/dags/openrc.sh',
openstack_command='openstack network list', openstack_command='openstack network list',
dag=dag) dag=dag)