Skip to content
This repository was archived by the owner on Jun 30, 2022. It is now read-only.

Commit a41b64b

Browse files
robertwbgildea
authored andcommitted
Initialize an empty executed_operations on MapTask
This is needed as it may be accessed by the reporting thread before the operations are fully populated. ----Release Notes---- [] ------------- Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=116896643
1 parent b9b0cd2 commit a41b64b

2 files changed

Lines changed: 1 addition & 1 deletion

File tree

google/cloud/dataflow/worker/batchworker.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -491,7 +491,6 @@ def run(self):
491491
with work_item.lock:
492492
self.set_current_work_item_and_executor(
493493
work_item, executor.MapTaskExecutor())
494-
work_item.map_task.executed_operations = []
495494
self.report_completion_status(
496495
work_item, exception_details=deferred_exception_details)
497496
work_item.done = True

google/cloud/dataflow/worker/maptask.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -551,6 +551,7 @@ def __init__(self, operations, stage_name, step_names):
551551
self.operations = operations
552552
self.stage_name = stage_name
553553
self.step_names = step_names
554+
self.executed_operations = []
554555

555556
def __str__(self):
556557
return '<%s %s steps=%s>' % (self.__class__.__name__, self.stage_name,

0 commit comments

Comments
 (0)