Skip to content

Commit 816aca4

Browse files
committed
add _ to hidden variable
1 parent 7160085 commit 816aca4

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

parsl/dataflow/dflow.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -754,10 +754,10 @@ def launch_task(self, task_record: TaskRecord) -> Future:
754754

755755
# hint executors that this function will be monitored
756756
if task_record['resource_specification']:
757-
task_record['resource_specification'].update({'is_monitoring_enabled': True})
757+
task_record['resource_specification'].update({'_is_monitoring_enabled': True})
758758
else:
759759
if task_record['resource_specification']:
760-
task_record['resource_specification'].update({'is_monitoring_enabled': False})
760+
task_record['resource_specification'].update({'_is_monitoring_enabled': False})
761761

762762
with self.submitter_lock:
763763
exec_fu = executor.submit(function, task_record['resource_specification'], *args, **kwargs)

parsl/executors/taskvine/executor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ def submit(self, func, resource_specification, *args, **kwargs):
342342

343343
logger.debug(f'Got resource specification: {resource_specification}')
344344

345-
is_monitoring_enabled = resource_specification.get('is_monitoring_enabled', False)
345+
is_monitoring_enabled = resource_specification.get('_is_monitoring_enabled', False)
346346

347347
# Default execution mode of apps is regular
348348
exec_mode = resource_specification.get('exec_mode', self.function_exec_mode)

0 commit comments

Comments
 (0)