Hello! I’m trying to understand how the airflow ingestion works. Does Datahub ingest logs from airflow or we need to send events from the task it self?

Hey there 👋 I'm The DataHub Community Support bot. I'm here to help make sure the community can best support you with your request. Let's double check a few things first: ✅ There's a lot of good information on our docs site: www.datahubproject.io/docs, Have you searched there for a solution? ✅ button ✅ It's not uncommon that someone has run into your exact problem before in the community. Have you searched Slack for similar issues? ✅ button Did you find a solution to your issue? ✅ Great! Glad to hear you were able to find a solution. 🙂

sorry, I marked yes by mistake

If you use Airflow’s Lineage api (setting inlets/outlets to your tasks the way how it is in our examples) then the plugin captures automatically. You just need to setup a datahub connection in Airflow and install our plugin. -> https://datahubproject.io/docs/lineage/airflow/

is there a way to connect it the other way around? otherwise it means to add the datahub to all exsiting dags/tasks right ?