티스토리 뷰
728x90
from datetime import datetime
from airflow.exceptions import AirflowSkipException
from airflow.models import DAG
from airflow.operators.dummy import DummyOperator
from airflow.operators.python import PythonOperator
with DAG(
dag_id="mydag",
start_date=datetime(2022, 1, 18),
schedule_interval="@once"
) as dag:
def task_b():
raise AirflowSkipException
A = DummyOperator(task_id="A")
B = PythonOperator(task_id="B", python_callable=task_b)
C = DummyOperator(task_id="C", trigger_rule="none_failed")
A >> B >> C
How to skip a task in airflow without skipping its downstream tasks?
Let’s say this is my dag: A >> B >> C If task B raises an exception, I want to skip the task instead of failing it. However, I don’t want to skip task C. I looked into AirflowSkipExcept...
stackoverflow.com
728x90
'공부' 카테고리의 다른 글
[docker] M1 MacOSX - no matching manifest for linux/arm64/v8 in the manifest list entries (0) | 2022.05.23 |
---|---|
[gradle] mavenCentral(), jCenter(), mavenLocal(), gradlePluginPortal() (0) | 2022.05.23 |
[Sh] array contains (0) | 2022.05.23 |
[Spring] kafka config (0) | 2022.05.22 |
[logback] kafka-appender (0) | 2022.05.22 |
댓글
250x250
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
TAG
- 모델 Y 레퍼럴
- 테슬라 레퍼럴 코드 확인
- 레퍼럴
- 테슬라 리퍼럴 코드
- 모델y
- 테슬라 리퍼럴 코드 혜택
- 클루지
- follower
- 연애학개론
- Kluge
- 팔로워 수 세기
- COUNT
- 할인
- 메디파크 내과 전문의 의학박사 김영수
- Bot
- 테슬라 레퍼럴
- 테슬라
- 테슬라 리퍼럴 코드 생성
- 테슬라 레퍼럴 적용 확인
- 책그림
- 인스타그램
- 김달
- 어떻게 능력을 보여줄 것인가?
- 개리마커스
- 테슬라 추천
- 유투브
- 테슬라 크레딧 사용
- wlw
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |
글 보관함