python 오퍼레이터 실행되지 않음
348
작성한 질문수 3
아래 코드 작동을 안합니다
어디가 잘못된 걸까요
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를 찾을 수 없다는 에러가 뜬다는 말일까요?
에러 로그를 같이 첨부해주시겠어요?
pykrx 회원제 전환으로 인한 실습 불가
0
109
2
수료증 발급
0
81
3
에러 발생 관련 질문드립니다.
0
80
2
vscode 작업화면에 오류가 발생하지 않습니다.
0
69
2
plugins 폴더 생성
0
74
2
WSL에서 git push 가 안되요 ㅠ
0
112
2
chatGPT&Airflow로 블로그 자동 포스팅하기 는 Deprecated 가 필요합니다.
0
66
2
github에 회원가입이 안되는데 원인이 뭔지 모르겠어요 ㅠ
0
721
2
설치중인데 venv를 꼭 써야할까요?
0
124
2
설치 버전 관련 질문입니다.
0
68
1
우분투 버전 다운받아야하는데 어떤걸로 설치해야할까요?
0
62
1
DAG 만들기 중 airflow 패키지 로드 에러
0
106
2
3.0에서도 수업노트가 성립하는지 확인 부탁드립니다!
0
95
3
task_id 사용법이 뭔가 바뀐 것 같습니다.
0
76
3
email operator 오류 관련
0
66
2
plugins 폴더 관련
0
95
2
bash operator 관련 문의입니다
0
78
3
스케쥴러 - DAG 파싱 부하 줄이는 과정 질문
0
79
2
Dags refresh 주기 관련 질문
0
123
2
wsl 관련 질문입니다.!
0
73
2
macOS에서 docker 설치
0
93
2
템플릿 변수에 대한 오류
0
61
2
custom_image 디렉토리 문의드립니다.
0
54
2
ETL 인터뷰 관련 문의
0
102
2





