인프런 커뮤니티 질문&답변

인프독학님의 프로필 이미지
인프독학

작성한 질문수

Airflow 마스터 클래스

Python 오퍼레이터 기본

python 오퍼레이터 실행되지 않음

작성

·

256

0

아래 코드 작동을 안합니다

 

어디가 잘못된 걸까요

 

operator 생성된게 보이지 않습니다

 

git pull까지 다한 상태입니다

 

from airflow import DAG
import pendulum
import datetime
from airflow.operators.python import PythonOperator
import random

with DAG(
    dag_id="dags_python_operator",
    schedule="30 6 * *",
    start_date=pendulum.datetime(2024, 1, 9, tz="Asia/Seoul"),
    catchup=False,
) as dag:
    def select_fruit():
        fruit = ['APPLE', 'BANANA', 'ORANGE', 'AVOCADO']
        rand_int = random.randint(0,3)
        print(fruit[rand_int])

    py_t1 = PythonOperator(
        task_id = 'py_t1',
        python_callable=select_fruit
    )

    py_t1

답변 1

0

김현진님의 프로필 이미지
김현진
지식공유자

안녕하세요 인프독학님!

혹시 operator 생성된게 보이지 않습니다 --> DAG이 안보인다는 말씀일까요?

아니면 pythonOperator를 찾을 수 없다는 에러가 뜬다는 말일까요?

에러 로그를 같이 첨부해주시겠어요?

인프독학님의 프로필 이미지
인프독학

작성한 질문수

질문하기