Airflow Python Operator Expand Energy