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
|
import uuid
import globus_sdk
from globus_sdk.testing import load_response
def test_submit(compute_client_v2: globus_sdk.ComputeClientV2):
meta = load_response(compute_client_v2.submit).metadata
ep_id, func_id = uuid.uuid1(), uuid.uuid1()
submit_doc = {
"task_group_id": meta["task_group_id"],
"create_websocket_queue": False,
"tasks": [
[func_id, ep_id, "36\n00\ngASVDAAAAAAAAACMBlJvZG5leZSFlC4=\n12 ..."],
[func_id, ep_id, "36\n00\ngASVCwAAAAAAAACMBUJvYmJ5lIWULg==\n12 ..."],
],
}
res = compute_client_v2.submit(data=submit_doc)
assert res.http_status == 200
assert res.data["task_group_id"] == meta["task_group_id"]
results = res.data["results"]
assert results[0]["task_uuid"] == meta["task_id"]
assert results[1]["task_uuid"] == meta["task_id_2"]
|
