From 65fb7ee22710c74771b04b905711e5603a7d9532 Mon Sep 17 00:00:00 2001 From: singhania Date: Thu, 10 Jan 2019 13:30:10 +0530 Subject: [PATCH] Fixed label to key method to generate correct key Key contains try number in long but current changes put that as string because of which keys are not getting removed from running dictionary. --- airflow/contrib/executors/kubernetes_executor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/contrib/executors/kubernetes_executor.py b/airflow/contrib/executors/kubernetes_executor.py index 84c0537ee5d91..502ba2bd78dd6 100644 --- a/airflow/contrib/executors/kubernetes_executor.py +++ b/airflow/contrib/executors/kubernetes_executor.py @@ -500,7 +500,7 @@ def _labels_to_key(self, labels): return ( labels['dag_id'], labels['task_id'], self._label_safe_datestring_to_datetime(labels['execution_date']), - labels['try_number']) + long(labels['try_number'])) except Exception as e: self.log.warn( 'Error while converting labels to key; labels: %s; exception: %s',