We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 324413d commit c28eb90Copy full SHA for c28eb90
airflow/requirements/modules.py
@@ -8,7 +8,7 @@ def collect_task_results(**context):
8
task_instances = context['dag_run'].get_task_instances()
9
task_states = {task_instance.task_id: task_instance.state for task_instance in task_instances}
10
11
- platform=''
+ platform='None'
12
for k, y in task_states:
13
if 'HOMEPLUS' in k:
14
platform = 'HOMEPLUS'
0 commit comments