airflow xcoms airflow xcoms airflow xcoms

Xcoms: Airflow

process_task = PythonOperator( task_id='process_task', python_callable=process_data, )

from datetime import datetime, timedelta from airflow import DAG from airflow.operators.bash_operator import BashOperator

If a task returns a value (specifically in PythonOperator), Airflow automatically pushes that value to XCom with the key return_value . This is the most common and cleanest method.

Here's an example of using XComs to pass data between tasks:

Full control over the UI

With additional themes, you can completely change everything that is on the screen. Add or remove UI elements, menu screens, whatever. Want to make it look like Kodi? Steam? Any other launcher? No problem. You can add animations and effects, 3D scenes, or even run your custom shader code.

Open source, cross platform, compatible with others

Pegasus can run on Linux, Windows, Mac, Raspberry Pi, Odroid and Android devices. It's compatible with EmulationStation metadata and gamelist files, and instantly recognizes your Steam games! airflow xcoms

airflow xcoms

process_task = PythonOperator( task_id='process_task', python_callable=process_data, )

from datetime import datetime, timedelta from airflow import DAG from airflow.operators.bash_operator import BashOperator

If a task returns a value (specifically in PythonOperator), Airflow automatically pushes that value to XCom with the key return_value . This is the most common and cleanest method.

Here's an example of using XComs to pass data between tasks: