File tree 2 files changed +98
-23
lines changed
2 files changed +98
-23
lines changed Original file line number Diff line number Diff line change 1
- # Table of contents
2
- # Learn more at https://jupyterbook.org/customize/toc.html
3
-
4
- format : jb-book
5
- root : welcome
6
- parts :
7
- - caption : Basic Concepts
8
- numbered : True
9
- chapters :
10
- - file : notebooks/1_intro_pydra
11
- - file : notebooks/2_intro_functiontask
12
- - file : notebooks/3_intro_functiontask_state
13
- - file : notebooks/4_intro_workflow
14
- - file : notebooks/5_intro_shelltask
15
- - caption : General Linear Model
16
- numbered : True
17
- chapters :
18
- - file : notebooks/6_firstlevel_glm_nilearn
19
- - file : notebooks/7_twolevel_glm_nilearn
20
- - caption : About Pydra
21
- chapters :
22
- - file : about/team
23
- - file : about/cite_pydra
1
+ # Table of contents
2
+ # Learn more at https://jupyterbook.org/customize/toc.html
3
+
4
+ format : jb-book
5
+ root : welcome
6
+ parts :
7
+ - caption : Basic Concepts
8
+ numbered : True
9
+ chapters :
10
+ - file : notebooks/1_intro_pydra
11
+ - file : notebooks/2_intro_functiontask
12
+ - file : notebooks/3_intro_functiontask_state
13
+ - file : notebooks/4_intro_workflow
14
+ - file : notebooks/5_intro_shelltask
15
+ - file : notebooks/8_intro_workers
16
+ - caption : General Linear Model
17
+ numbered : True
18
+ chapters :
19
+ - file : notebooks/6_firstlevel_glm_nilearn
20
+ - file : notebooks/7_twolevel_glm_nilearn
21
+ - caption : About Pydra
22
+ chapters :
23
+ - file : about/team
24
+ - file : about/cite_pydra
Original file line number Diff line number Diff line change
1
+ ---
2
+ jupytext :
3
+ text_representation :
4
+ extension : .md
5
+ format_name : myst
6
+ format_version : 0.13
7
+ jupytext_version : 1.14.0
8
+ kernelspec :
9
+ display_name : Python 3
10
+ language : python
11
+ name : python3
12
+ ---
13
+
14
+ # Workers in Pydra
15
+
16
+ Pydra workers are classes that are used to execute ` Tasks ` and ` Workflows ` . Pydra currently supports the following workers:
17
+ - ` SerialWorker `
18
+ - ` ConcurrentFuturesWorker `
19
+ - ` SlurmWorker `
20
+ - ` DaskWorker `
21
+ - ` SGEWorker `
22
+ - ` PsijWorker `
23
+
24
+ ## 1. SerialWorker
25
+
26
+ A worker to execute linearly.
27
+ ```
28
+ with pydra.Submitter(plugin='serial') as sub:
29
+ sub(wf)
30
+ ```
31
+
32
+ ## 2. ConcurrentFuturesWorker
33
+
34
+ A worker to execute in parallel using Python's concurrent futures.
35
+ ```
36
+ with pydra.Submitter(plugin='cf') as sub:
37
+ sub(wf)
38
+ ```
39
+
40
+ ## 3. SlurmWorker
41
+
42
+ A worker to execute tasks on SLURM systems.
43
+ ```
44
+ with pydra.Submitter(plugin='slurm') as sub:
45
+ sub(wf)
46
+ ```
47
+
48
+ ## 4. DaskWorker
49
+
50
+ A worker to execute in parallel using Dask.distributed.
51
+ ```
52
+ with pydra.Submitter(plugin='dask') as sub:
53
+ sub(wf)
54
+ ```
55
+
56
+ ## 5. SGEWorker
57
+
58
+ A worker to execute tasks on SLURM systems.
59
+ ```
60
+ with pydra.Submitter(plugin='sge') as sub:
61
+ sub(wf)
62
+ ```
63
+
64
+ ## 6. PsijWorker
65
+
66
+ A worker to execute tasks using PSI/J executors. Currently supported executors are: ` local ` and ` slurm ` .
67
+ ```
68
+ with pydra.Submitter(plugin='psij-local') as sub:
69
+ sub(wf)
70
+ ```
71
+ ```
72
+ with pydra.Submitter(plugin='psij-slurm') as sub:
73
+ sub(wf)
74
+ ```
You can’t perform that action at this time.
0 commit comments