Index: plaso/multi_processing/task_engine.py |
diff --git a/plaso/multi_processing/task_engine.py b/plaso/multi_processing/task_engine.py |
index 54af03ff907692ffd615512e1c14d6251d3579f2..5f94172492298734be4809719850e8fe767b1a1c 100644 |
--- a/plaso/multi_processing/task_engine.py |
+++ b/plaso/multi_processing/task_engine.py |
@@ -45,13 +45,13 @@ class _EventSourceHeap(object): |
"""Pops an event source from the heap. |
Returns: |
- EventSource: event source. |
+ EventSource: event source or None on error. |
""" |
try: |
_, event_source = heapq.heappop(self._heap) |
except IndexError: |
- return |
+ return None |
return event_source |
@@ -504,7 +504,7 @@ class TaskMultiProcessEngine(engine.MultiProcessEngine): |
process_name, pid, exception)) |
self._TerminateProcess(process) |
- return |
+ return None |
self._RegisterProcess(process) |