Skip to content

Commit fb53ba2

Browse files
add retry for airflow ParsingError
1 parent 5e7aa6b commit fb53ba2

File tree

1 file changed

+20
-4
lines changed

1 file changed

+20
-4
lines changed

tests/integ/test_airflow_config.py

+20-4
Original file line numberDiff line numberDiff line change
@@ -16,10 +16,26 @@
1616

1717
import pytest
1818
import numpy as np
19-
from airflow import utils
20-
from airflow import DAG
21-
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperator
22-
from airflow.providers.amazon.aws.operators.sagemaker_transform import SageMakerTransformOperator
19+
from configparser import ParsingError
20+
from sagemaker.utils import retries
21+
22+
for _ in retries(
23+
max_retry_count=10, # 10*6 = 1min
24+
exception_message_prefix="airflow import ",
25+
seconds_to_sleep=6,
26+
):
27+
try:
28+
from airflow import utils
29+
from airflow import DAG
30+
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperator
31+
from airflow.providers.amazon.aws.operators.sagemaker_transform import (
32+
SageMakerTransformOperator,
33+
)
34+
35+
break
36+
except ParsingError:
37+
pass
38+
2339
from six.moves.urllib.parse import urlparse
2440

2541
import tests.integ

0 commit comments

Comments
 (0)