NTC4818

icon company KCF Technologies icon location Data Analyst, aspiring data scientist interested in machine learning and AI

Results 12 comments of NTC4818

Issue while running the DAG

Yes that makes good sense to change the import. Maybe that will trigger the dag to be setup correctly, I will tear down and rebuild, I appreciate the input I...

Issue while running the DAG

Even after attempting to install on Docker container running airflow I get this error. Broken DAG: [/usr/local/airflow/dags/stream_to_kafka_dag.py] No module named 'kafka'