작성
·
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를 찾을 수 없다는 에러가 뜬다는 말일까요?
에러 로그를 같이 첨부해주시겠어요?