0
respostas

[Bug] ERRO NA EXECUÇÃO DA DAG

Segue meu codigo e o erro na execução

import yfinance
from airflow.decorators import dag, task
from airflow.macros import ds_add
from pathlib import Path
import pendulum

TICKERS = [
            "AAPL",
            "MSFT",
            "GOOG",
            "TSLA"
            ]

@task()

def get_history(ticker, ds=None, ds_nodash=None):
        file_path = f"/home/nayara/Downloads/EngDados/ALURA/airflow2/stocks/{ticker}//{ticker}_{ds_nodash}.csv"
        yfinance.Ticker(ticker).history(
            period ="1d",
            interval = "1h",
            start = ds_add(ds, -1),
            end = ds,
            prepost = True
                        ).to_csv(file_path)

@dag(
    schedule_interval="0 0 * * 2-6",
    start_date=pendulum.datetime(2022, 1, 1, tz="UTC"),
    catchup=True
)
def get_stocks_dag():
    for ticker in TICKERS:
        get_history.override(task_id=ticker)(ticker)   

dag = get_stocks_dag()![Insira aqui a descrição dessa imagem para ajudar na acessibilidade](https://cdn1.gnarususercontent.com.br/1/955116/3667f98e-1de9-476c-8d76-c47f34912da0.png)  

Insira aqui a descrição dessa imagem para ajudar na acessibilidade