Parent must re-raise MemoryError and crash

ask · ask · commit 2f0d4a0c82a2 · 2013-05-22T16:03:12.000+01:00
diff --git a/celery/worker/job.py b/celery/worker/job.py
@@ -412,6 +412,8 @@ def _log_error(self, einfo):
         )
 
         if internal:
+            if isinstance(einfo.exception, MemoryError):
+                raise MemoryError('Process got: %s' % (einfo.exception, ))
             if isinstance(einfo.exception, Ignore):
                 format = self.ignored_msg
                 description = 'ignored'

Original file line number	Diff line number	Diff line change
`@@ -412,6 +412,8 @@ def _log_error(self, einfo):`
`412`	`412`	`)`
`413`	`413`
`414`	`414`	`if internal:`
	`415`	`+ if isinstance(einfo.exception, MemoryError):`
	`416`	`+ raise MemoryError('Process got: %s' % (einfo.exception, ))`
`415`	`417`	`if isinstance(einfo.exception, Ignore):`
`416`	`418`	`format = self.ignored_msg`
`417`	`419`	`description = 'ignored'`