1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
import globus_sdk
from globus_sdk.testing import load_response
def test_submit(compute_client_v3: globus_sdk.ComputeClientV3):
meta = load_response(compute_client_v3.submit).metadata
submit_doc = {
"tasks": {
meta["function_id"]: [
"36\n00\ngASVDAAAAAAAAACMBlJvZG5leZSFlC4=\n12 ...",
"36\n00\ngASVCwAAAAAAAACMBUJvYmJ5lIWULg==\n12 ...",
],
},
"task_group_id": meta["task_group_id"],
"create_queue": True,
"user_runtime": {
"globus_compute_sdk_version": "2.29.0",
"globus_sdk_version": "3.46.0",
"python_version": "3.11.9",
},
}
res = compute_client_v3.submit(endpoint_id=meta["endpoint_id"], data=submit_doc)
assert res.http_status == 200
assert res.data["request_id"] == meta["request_id"]
assert res.data["task_group_id"] == meta["task_group_id"]
assert res.data["endpoint_id"] == meta["endpoint_id"]
assert res.data["tasks"] == {
meta["function_id"]: [meta["task_id"], meta["task_id_2"]]
}
|
