How to retire a worker and retry its job?
We're noticing that every so often, a worker gets corrupted, and doesn't produce correct output. It's easy enough for us to detect it inside the handler when it happens. Is there a built-in way to tell runpod the job failed, the worker is bad, and it should be refreshed and requeued? Or should I do this manually with "refresh_worker" and use the API to requeue?
Solution
Ohhh ashelyk is right u can just return a true to selectively do it. I just read the how to do it on start but not the return:
Return
Example:
```python
def handler_with_selective_refresh(job):
if job["input"].get("refresh", False):
# Handle the job and return the output with refresh_worker flag
return {"output": "Job completed successfully", "refresh_worker": True}
else:
# Handle the job and return the output
return {"output": "Job completed successfully"}
Return
refresh_worker=TrueExample:
```python
def handler_with_selective_refresh(job):
if job["input"].get("refresh", False):
# Handle the job and return the output with refresh_worker flag
return {"output": "Job completed successfully", "refresh_worker": True}
else:
# Handle the job and return the output
return {"output": "Job completed successfully"}
