Importar codigos externos

Oii, Gabriel! Tudo bem?

O erro indica que Python não consegue encontrar o módulo producao ao ser importado no script Airflow. Você está no caminho certo, criando o arquivo __init__.py. Porém, só isso pode não ser suficiente se o Python não estiver reconhecendo o caminho até esse diretório.

Uma possível solução é garantir que o diretório producao esteja no PYTHONPATH do ambiente onde o Airflow está rodando. Você pode fazer isso adicionando uma linha de código no início do seu script Implemaster.py para incluir explicitamente o caminho até o diretório producao. Segue um exemplo:

import sys
sys.path.insert(0, "/opt/airflow/producao")

from producao import implemaster

Neste exemplo acima, é adicionado o diretório producao ao início do PYTHONPATH, o que deve permitir que o Python encontre os módulos dentro dele.

Além disso, verifique se o volume está montado corretamente no Docker Compose, como você configurou. Às vezes, erros de digitação ou caminhos incorretos podem causar problemas. Revise se o caminho que indica para o diretório producao condiz, no seu sistema local.

Espero que as sugestões te ajude. Qualquer dúvida, conte conosco.

Bons estudos, Gabriel!

Olá, obrigado pelo retorno mas não deu certo. Vou compartilhar o codigo quem sabe fiz algo errado.

from airflow.models import DAG
from airflow.utils.dates import days_ago
from airflow.operators.empty import EmptyOperator
from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator
import pendulum
import sys

sys.path.insert(0, "/opt/airflow/producao")

from producao import implemaster

with DAG(
    'Implemaster',
    start_date=pendulum.datetime(2024, 5, 9, tz="UTC"),
    schedule_interval='@daily'
) as dag:
    
    tarefa_1 = PythonOperator(
        task_id = 'Extrair_Dados',
        python_callable=implemaster.Imbaud().clifor()
    )

    tarefa_1

Olá! este script está fazendo uma conexão com o firebird! será que é por isto ?