Segue meu código
from datetime import datetime
from os.path import join
from airflow.models import DAG
from operators.twitter_operator import TwitterOperator
with DAG(dag_id="twitter_dag", start_date=datetime.now()) as dag:
twitter_operator = TwitterOperator(
task_id="twitter_aluraonline",
query="AluraOnline",
file_path=join(
"/home/nayara/datapipeline/datalake",
"twitter_aluraonline",
"extract_date={{ ds }}",
"AluraOnline_{{ ds_nodash }}.json"
)
)os erros que aparecem são os seguintes
