We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ff1a575 commit d23389eCopy full SHA for d23389e
1 file changed
server/neptune/temporalworker/job/store.go
@@ -209,6 +209,7 @@ func (s *StorageBackendJobStore) Remove(jobID string) {
209
func (s *StorageBackendJobStore) Cleanup(ctx context.Context) error {
210
failedJobs := []string{}
211
for jobID, job := range s.InMemoryStore.GetJobs() {
212
+ s.logger.WarnContext(ctx, fmt.Sprintf("job: %s was not persisted before shutdown, persisting now during cleanup", jobID))
213
_, err := s.storageBackend.Write(ctx, jobID, job.Output)
214
215
// Track failed jobs, log errors and continue with other jobs
0 commit comments