From d956a5317b6d75b4f8e0fe12101f59759fde73c5 Mon Sep 17 00:00:00 2001 From: Rafael Date: Wed, 18 Oct 2023 09:15:58 -0300 Subject: [PATCH] corrigir logica de recaptura --- pipelines/rj_smtr/flows.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pipelines/rj_smtr/flows.py b/pipelines/rj_smtr/flows.py index b951a18a4..a63d8681d 100644 --- a/pipelines/rj_smtr/flows.py +++ b/pipelines/rj_smtr/flows.py @@ -76,7 +76,9 @@ with case(recapture, False): capture_timestamp = [get_current_timestamp()] - previous_errors = [None] + previous_errors = task( + lambda: [None], checkpoint=False, name="assign_none_to_previous_errors" + )() timestamps = merge(recapture_timestamps, capture_timestamp)