Skip to content

Commit c493fe6

Browse files
committed
Remove retry_id in Airflow job name, needs more design on this
1 parent 4ffdeda commit c493fe6

File tree

3 files changed

+102
-120
lines changed

3 files changed

+102
-120
lines changed

CHANGELOG.rst

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,7 @@ CHANGELOG
55
1.16.3
66
======
77

8-
* bug-fix: Local Mode: Allow support for SSH in local mode
9-
* bug-fix: Append retry id to default Airflow job name to avoid name collisions in retry
8+
* bug-fix: Local Mode: Allow support for SSH in local mode
109
* bug-fix: Local Mode: No longer requires s3 permissions to run local entry point file
1110
* feature: Estimators: add support for PyTorch 1.0.0
1211
* bug-fix: Local Mode: Move dependency on sagemaker_s3_output from rl.estimator to model

src/sagemaker/utils.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,10 @@
2727
import six
2828

2929

30-
AIRFLOW_RETRY_MACRO = "{{ task_instance.try_number }}"
31-
AIRFLOW_TIME_MACRO = "{{ execution_date.strftime('%Y-%m-%d-%H-%M-%S') }}" + "-{}".format(AIRFLOW_RETRY_MACRO)
32-
AIRFLOW_TIME_MACRO_LEN = 22
33-
AIRFLOW_TIME_MACRO_SHORT = "{{ execution_date.strftime('%y%m%d-%H%M') }}" + "-{}".format(AIRFLOW_RETRY_MACRO)
34-
AIRFLOW_TIME_MACRO_SHORT_LEN = 14
30+
AIRFLOW_TIME_MACRO = "{{ execution_date.strftime('%Y-%m-%d-%H-%M-%S') }}"
31+
AIRFLOW_TIME_MACRO_LEN = 19
32+
AIRFLOW_TIME_MACRO_SHORT = "{{ execution_date.strftime('%y%m%d-%H%M') }}"
33+
AIRFLOW_TIME_MACRO_SHORT_LEN = 11
3534

3635

3736
# Use the base name of the image as the job name if the user doesn't give us one

0 commit comments

Comments
 (0)