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',