Boa tarde!
Minhas DAGs estão funcionando normalmente caso execute-as manualmente pelo bash, mas o airflow não consegue localizar o módulo 'TwitterOperator'. Configurei corretamente as variáveis de ambiente, então pelo comando $ airflow list_dags
ele já consegue exibir, mas no webserver não. Alguma ideia de como posso resolver?
Obrigado,
Olá, Jonatas! Tudo tranquilo por aí?
Primeiramente gostaria de pedir desculpas pela demora em te retornar.
Esse comportamento inesperado encontrado por você está acontecendo pois o import que você está realizando não é o adequado. Você está realizando o import da seguinte forma:
from airflow.operators import TwitterOperatorE conforme o instrutor demonstra em aula, a forma correta é:
from operators.twitter_operator import TwitterOperatorTente fazer essa substituição e verifique se funciona corretamente.
Espero ter ajudado e estou sempre à disposição quando tiver alguma dúvida.
:)