Skip to content

Commit

Permalink
Updated RetryOnExceptionError class for handling task retries with cu…
Browse files Browse the repository at this point in the history
…stom logic

- Implement updating callbackAfterSeconds inside task by using retry_delay_seconds
  • Loading branch information
julian-gula committed Sep 27, 2024
1 parent ebf2eb6 commit 379df90
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion frinx/common/worker/exception.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ def update_task_result(self, task, task_result: TaskResult) -> TaskResult:

if self._should_retry(current_poll_count):
task_result.status = TaskResultStatus.IN_PROGRESS
# task_result.callable_after_seconds = self.retry_delay # TODO: Setting delay before it can be retried
task["callbackAfterSeconds"] = self.retry_delay_seconds
else:
task_result.status = TaskResultStatus.FAILED

Expand Down

0 comments on commit 379df90

Please sign in to comment.