Solucionado (ver solução)
Solucionado
(ver solução)
3
respostas

Problemas no import TwitterOperator

Estou com problemas no import, ele não consegue identificar o módulo com nome "alura" criado no de airflow_plugin.py Insira aqui a descrição dessa imagem para ajudar na acessibilidade

Alguem conseguiu arrumar? Verifiquei que ta cheio desse erro, mas nenhum resolvido...

3 respostas

Segue o meu código: Insira aqui a descrição dessa imagem para ajudar na acessibilidade

Onde está o Plugin: Insira aqui a descrição dessa imagem para ajudar na acessibilidade

solução!

Tive o mesmo problema, resolvi da seguinte forma:

Deixa o twitter_operator.py dentro da pasta plugins

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

No arquivo twitter_dag.py, utilize o seguinte import: from twitter_operator import TwitterOperator

Você deve deletar o arquivo airflow_plugin.py

Eu entendi que occoreu uma alteração no modo de declarar e importar custom operators no Airflow. https://airflow.apache.org/docs/apache-airflow/stable/howto/custom-operator.html

Uma outra opção é manter a pasta operators dentro de plugins e no import em dag usar:

from operators.twitter_operator import TwitterOperator

Estou usando a versão 2.3.0 e funcionou de boas.

Ainda procurando se na documentação tem algo que restrinja o que eu usei.