Skip to content

Commit 8023377

Browse files
committed
Fix for retry_count issue
1 parent a819ea4 commit 8023377

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

bfi_dagster_project/sensors/__init__.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -71,13 +71,10 @@ def failed_encoding_retry_sensor(
7171
f"Key prefix {key_prefix} does not match sequence {key}"
7272
)
7373
continue
74-
retry_count = seq[17]
75-
if not retry_count:
76-
retry_count = 0
77-
elif not retry_count.isnumeric():
78-
retry_count = 0
79-
else:
80-
retry_count = int(retry_count)
74+
75+
retry_count = 0
76+
if seq[17] is not None:
77+
retry_count = int(seq[17])
8178

8279
if retry_count > 3:
8380
context.log.warning(

0 commit comments

Comments
 (0)