Skip to content

Commit 9a3f2f7

Browse files
committed
Merge branch 'feature-hw' of https://github.com/killerdbob/skyplane into feature-hw
2 parents c3b6f91 + f78bd7c commit 9a3f2f7

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

skyplane/gateway/operators/gateway_operator.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,14 @@ def worker_loop(self, worker_id: int, *args):
9090
# TODO: status logging
9191
self.chunk_store.log_chunk_state(chunk_req, ChunkState.in_progress, operator_handle=self.handle, worker_id=worker_id)
9292
# process chunk
93-
succ = self.process(chunk_req, *args)
93+
succ = retry_backoff(
94+
partial(
95+
self.process,
96+
chunk_req,
97+
*args
98+
),
99+
max_retries=1,
100+
)
94101

95102
# place in output queue
96103
if succ:

0 commit comments

Comments
 (0)