Skip to content

Commit

Permalink
Bump parsl dependency to 2024.10.21
Browse files Browse the repository at this point in the history
  • Loading branch information
rjmello committed Oct 24, 2024
1 parent e75957f commit 7c1ca1f
Show file tree
Hide file tree
Showing 5 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
Changed
^^^^^^^

- Bumped ``parsl`` dependency version to `2024.10.21 <https://pypi.org/project/parsl/2024.10.21/>`_.
2 changes: 1 addition & 1 deletion compute_endpoint/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@
# 'parsl' is a core requirement of the globus-compute-endpoint, essential to a range
# of different features and functions
# pin exact versions because it does not use semver
"parsl==2024.9.9",
"parsl==2024.10.21",
"pika>=1.2.0",
"pyprctl<0.2.0",
"setproctitle>=1.3.2,<1.4",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -326,5 +326,5 @@ def test_bad_resource_specification(
result = unpack(mbody)
break
assert result.task_id == task_uuid
assert "Invalid resource specification options supplied: BAD_KEY" in result.data
assert "Invalid Resource Specification Supplied: {'BAD_KEY'}" in result.data
assert result.error_details.code == "RemoteExecutionError"
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,7 @@
from globus_compute_common import messagepack
from globus_compute_common.messagepack.message_types import Result, Task
from globus_compute_sdk import Client
from parsl.executors.high_throughput.mpi_prefix_composer import (
InvalidResourceSpecification,
)
from parsl.executors.errors import InvalidResourceSpecification


class MockExecutor(unittest.mock.Mock):
Expand Down Expand Up @@ -42,7 +40,7 @@ def submit(

# This is a hack to trigger an InvalidResourceSpecification
if "BAD_KEY" in resource_specification:
raise InvalidResourceSpecification("BAD_KEY")
raise InvalidResourceSpecification({"BAD_KEY"})

packed_result = messagepack.pack(res)
msg = {"task_id": str(task_id), "message": packed_result}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,7 @@
from globus_compute_endpoint.engines import GlobusMPIEngine
from globus_compute_sdk.sdk.mpi_function import MPIFunction
from globus_compute_sdk.sdk.shell_function import ShellResult
from parsl.executors.high_throughput.mpi_prefix_composer import (
InvalidResourceSpecification,
)
from parsl.executors.errors import InvalidResourceSpecification
from tests.utils import get_env_vars


Expand Down

0 comments on commit 7c1ca1f

Please sign in to comment.