Skip to content

Commit

Permalink
Execute on _parsl_internal, and add a TODO about choosing which DFK t…
Browse files Browse the repository at this point in the history
…o execute on
  • Loading branch information
benclifford committed Oct 9, 2023
1 parent 6efedb5 commit 9036a7e
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion parsl/dataflow/futures.py
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,12 @@ def outputs(self) -> Sequence[DataFuture]:
def __getitem__(self, key: Any) -> AppFuture:
# hack around circular imports for python_app
from parsl.app.app import python_app
deferred_getitem_app = python_app(deferred_getitem)

# TODO: this should be run on the same DFK as is executing the
# task that is associated with this future. That value isn't
# easily available here (although probably the right thing to
# do is add it to self.task_def)
deferred_getitem_app = python_app(deferred_getitem, executors=['_parsl_internal'])

return deferred_getitem_app(self, key)

Expand Down

0 comments on commit 9036a7e

Please sign in to comment.