MAINT: add threads/jobs primitives (#61)

qiime2 · Feb 13, 2024 · 2fddbf0 · 2fddbf0
1 parent c78541c
commit 2fddbf0
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/q2_cutadapt/plugin_setup.py b/q2_cutadapt/plugin_setup.py
@@ -17,6 +17,7 @@
     List,
     Str,
     Bool,
+    Threads,
 )
 from q2_types.multiplexed_sequences import (
     MultiplexedSingleEndBarcodeInSequence,
@@ -53,7 +54,7 @@
         'demultiplexed_sequences': SampleData[SequencesWithQuality],
     },
     parameters={
-        'cores': Int % Range(1, None),
+        'cores': Threads,
         'adapter': List[Str],
         'front': List[Str],
         'anywhere': List[Str],
@@ -144,7 +145,7 @@
         'demultiplexed_sequences': SampleData[PairedEndSequencesWithQuality],
     },
     parameters={
-        'cores': Int % Range(1, None),
+        'cores': Threads,
         'adapter_f': List[Str],
         'front_f': List[Str],
         'anywhere_f': List[Str],
@@ -267,7 +268,7 @@
         'batch_size': Int % Range(0, None),
         'minimum_length': Int % Range(1, None),
         'cut': Int,
-        'cores': Int % Range(1, None),
+        'cores': Threads,
     },
     outputs=[
         ('per_sample_sequences', SampleData[SequencesWithQuality]),
@@ -334,7 +335,7 @@
         'batch_size': Int % Range(0, None),
         'minimum_length': Int % Range(1, None),
         'mixed_orientation': Bool,
-        'cores': Int % Range(1, None),
+        'cores': Threads,
     },
     outputs=[
         ('per_sample_sequences', SampleData[PairedEndSequencesWithQuality]),