Skip to content

Commit 133a9f7

Browse files
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
1 parent 8c7a833 commit 133a9f7

File tree

1 file changed

+4
-12
lines changed

1 file changed

+4
-12
lines changed

docs/source/examples/basic_task_label.py

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -23,25 +23,17 @@ def wait(t):
2323
if balanced_view:
2424
# use load balanced view
2525
dview = rc.load_balanced_view()
26-
ar_list = [
27-
dview.map_async(wait, [2], label=f"mylabel_{i:02}") for i in range(10)
28-
]
26+
ar_list = [dview.map_async(wait, [2], label=f"mylabel_{i:02}") for i in range(10)]
2927
dview.wait(ar_list)
3028
else:
3129
# use direct view
3230
dview = rc[:]
33-
ar_list = [
34-
dview.apply_async(wait, 2, label=f"mylabel_{i:02}") for i in range(10)
35-
]
31+
ar_list = [dview.apply_async(wait, 2, label=f"mylabel_{i:02}") for i in range(10)]
3632
dview.wait(ar_list)
3733

3834
# query database
39-
data = rc.db_query(
40-
{'label': {"$nin": ""}}, keys=['msg_id', 'label', 'engine_uuid']
41-
)
35+
data = rc.db_query({'label': {"$nin": ""}}, keys=['msg_id', 'label', 'engine_uuid'])
4236
for d in data:
43-
print(
44-
f"msg_id={d['msg_id']}; label={d['label']}; engine_uuid={d['engine_uuid']}"
45-
)
37+
print(f"msg_id={d['msg_id']}; label={d['label']}; engine_uuid={d['engine_uuid']}")
4638

4739
cluster.stop_cluster_sync()

0 commit comments

Comments
 (0)