• 카테고리

    질문 & 답변
  • 세부 분야

    데이터 엔지니어링

  • 해결 여부

    미해결

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

24.01.09 00:15 작성 조회수 175

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를 찾을 수 없다는 에러가 뜬다는 말일까요?

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