-
Notifications
You must be signed in to change notification settings - Fork 187
/
Copy pathexample_customize_operator.yml
46 lines (45 loc) · 1.19 KB
/
example_customize_operator.yml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
default:
default_args:
owner: "default_owner"
start_date: 2020-01-01
retries: 1
retry_delay_sec: 300
concurrency: 1
max_active_runs: 1
dagrun_timeout_sec: 600
default_view: "tree"
orientation: "LR"
schedule_interval: "0 1 * * *"
example_breadfast:
default_args:
owner: "custom_owner"
start_date: 2 days
description: "this is an customized operator dag"
schedule_interval: "0 3 * * *"
tasks:
begin:
operator: airflow.operators.dummy_operator.DummyOperator
make_bread_1:
operator: customized.operators.breakfast_operators.MakeBreadOperator
bread_type: 'Sourdough'
dependencies:
- begin
make_bread_2:
operator: customized.operators.breakfast_operators.MakeBreadOperator
bread_type: 'Multigrain'
dependencies:
- begin
make_coffee_1:
operator: customized.operators.breakfast_operators.MakeCoffeeOperator
coffee_type: 'Black'
dependencies:
- begin
- make_bread_1
- make_bread_2
end:
operator: airflow.operators.dummy_operator.DummyOperator
dependencies:
- begin
- make_bread_1
- make_bread_2
- make_coffee_1