perry2of5 opened a new pull request, #48557: URL: https://github.com/apache/airflow/pull/48557
This handles overflow when calculating the next execution time for a task instance by falling back to the configured maximum delay. The solution uses the same strategy that tenacity uses: https://github.com/jd/tenacity/blob/main/tenacity/wait.py#L167 An alternate solution would be the determine the maximum tries that wouldn't exceed the maximum delay and then not calculate the timeout for values larger than that. Something like ``` max_delay = self.task.max_retry_delay if self.task.max_retry_delay is not null else MAX_RETRY_DELAY tries_before_max_delay = math.floor(math.log2(max_delay)) if self.try_number <= tries_before_max_delay: # existing logic else: delay = max_delay ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
