Nextflow recipe

brianetz · brianetz · commit fc9de8e42b05 · 2025-06-18T15:09:46.000-04:00
diff --git a/MANIFEST.in b/MANIFEST.in
@@ -1,3 +1,6 @@
+graft wfcommons/wfchef/recipes/rnaseq/microstructures/**
+graft wfcommons/wfchef/recipes/rnaseq/microstructures
+graft wfcommons/wfchef/recipes/rnaseq
 graft wfcommons/wfchef/recipes/epigenomics/microstructures/**
 graft wfcommons/wfchef/recipes/epigenomics/microstructures
 graft wfcommons/wfchef/recipes/epigenomics
diff --git a/setup.py b/setup.py
@@ -49,6 +49,7 @@ def run(self):
             'genome_recipe = wfcommons.wfchef.recipes:GenomeRecipe',
             'blast_recipe = wfcommons.wfchef.recipes:BlastRecipe',
             'bwa_recipe = wfcommons.wfchef.recipes:BwaRecipe',
+            'rnaseq_recipe = wfcommons.wfchef.recipes:RnaseqRecipe',
         ]
     },
 )
diff --git a/wfcommons/common/task.py b/wfcommons/common/task.py
@@ -87,7 +87,7 @@ def __init__(self,
                  energy: Optional[int] = None,
                  avg_power: Optional[float] = None,
                  priority: Optional[int] = None,
-                 executedAt: Optional[str] = None,
+                 executed_at: Optional[str] = None,
                  task_type: Optional[TaskType] = None,
                  launch_dir: Optional[str] = None,
                  logger: Optional[Logger] = None,
@@ -114,7 +114,7 @@ def __init__(self,
         self.priority: Optional[int] = priority
         self.type: Optional[TaskType] = task_type
         self.launch_dir: Optional[str] = launch_dir
-        self.start_time: Optional[str] = str(datetime.now().astimezone().isoformat()) if not executedAt else executedAt
+        self.start_time: Optional[str] = str(datetime.now().astimezone().isoformat()) if not executed_at else executed_at
         self.logger.debug(
             f"created task {self.task_id}: runtime => {self.runtime} seconds.")
 
diff --git a/wfcommons/wfchef/recipes/__init__.py b/wfcommons/wfchef/recipes/__init__.py
@@ -18,3 +18,4 @@
 from .genome import GenomeRecipe
 from .blast import BlastRecipe
 from .bwa import BwaRecipe
+from .rnaseq import RnaseqRecipe
diff --git a/wfcommons/wfchef/recipes/rnaseq/__init__.py b/wfcommons/wfchef/recipes/rnaseq/__init__.py
@@ -0,0 +1 @@
+from .recipe import RnaseqRecipe
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/metric/err.csv b/wfcommons/wfchef/recipes/rnaseq/microstructures/metric/err.csv
@@ -0,0 +1,4 @@
+,rnaseq-3l,rnaseq-6l
+rnaseq-t1l,0.004108531398080609,0.004108531398080609
+rnaseq-3l,0.0,0.0
+rnaseq-6l,,0.0
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-3l/base_graph.pickle b/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-3l/base_graph.pickle
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-3l/microstructures.json b/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-3l/microstructures.json
@@ -0,0 +1 @@
+{}
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-6l/base_graph.pickle b/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-6l/base_graph.pickle
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-6l/microstructures.json b/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-6l/microstructures.json
@@ -0,0 +1 @@
+{}
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-t1l/base_graph.pickle b/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-t1l/base_graph.pickle
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-t1l/microstructures.json b/wfcommons/wfchef/recipes/rnaseq/microstructures/rnaseq-t1l/microstructures.json
@@ -0,0 +1 @@
+{}
diff --git a/wfcommons/wfchef/recipes/rnaseq/microstructures/summary.json b/wfcommons/wfchef/recipes/rnaseq/microstructures/summary.json
@@ -0,0 +1,17 @@
+{
+  "frequencies": {},
+  "base_graphs": {
+    "rnaseq-t1l": {
+      "size": 126,
+      "order": 65
+    },
+    "rnaseq-3l": {
+      "size": 128,
+      "order": 66
+    },
+    "rnaseq-6l": {
+      "size": 128,
+      "order": 66
+    }
+  }
+}
diff --git a/wfcommons/wfchef/recipes/rnaseq/recipe.py b/wfcommons/wfchef/recipes/rnaseq/recipe.py
@@ -0,0 +1,61 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+#
+# Copyright (c) 2021 The WfCommons Team.
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+import pathlib
+from logging import Logger
+from typing import Optional, Set
+import pathlib 
+from wfcommons.wfchef.wfchef_abstract_recipe import BaseMethod, WfChefWorkflowRecipe
+
+this_dir = pathlib.Path(__file__).resolve().parent
+
+
+class RnaseqRecipe(WfChefWorkflowRecipe):
+    """A Rnaseq workflow recipe class for creating synthetic workflow instances.
+
+    :param data_footprint: The upper bound for the workflow total data footprint (in bytes).
+    :type data_footprint: int
+    :param num_tasks: The upper bound for the total number of tasks in the workflow.
+    :type num_tasks: int
+    :param exclude_graphs:
+    :type exclude_graphs: Set
+    :param runtime_factor: The factor of which tasks runtime will be increased/decreased.
+    :type runtime_factor: float
+    :param input_file_size_factor: The factor of which tasks input files size will be increased/decreased.
+    :type input_file_size_factor: float
+    :param output_file_size_factor: The factor of which tasks output files size will be increased/decreased.
+    :type output_file_size_factor: float
+    :param logger: The logger where to log information/warning or errors (optional).
+    :type logger: Logger
+    """
+
+    def __init__(self,
+                 data_footprint: Optional[int] = 0,
+                 num_tasks: Optional[int] = 3,
+                 exclude_graphs: Set[str] = set(),
+                 runtime_factor: Optional[float] = 1.0,
+                 input_file_size_factor: Optional[float] = 1.0,
+                 output_file_size_factor: Optional[float] = 1.0,
+                 logger: Optional[Logger] = None,
+                 base_method: BaseMethod = BaseMethod.ERROR_TABLE,
+                 **kwargs) -> None:
+        super().__init__(
+            name="Rnaseq", 
+            data_footprint=data_footprint, 
+            num_tasks=num_tasks, 
+            exclude_graphs=exclude_graphs, 
+            runtime_factor=runtime_factor, 
+            input_file_size_factor=input_file_size_factor,
+            output_file_size_factor=output_file_size_factor, 
+            logger=logger, 
+            this_dir=this_dir, 
+            base_method=base_method,
+            **kwargs
+        )
diff --git a/wfcommons/wfchef/recipes/rnaseq/task_type_stats.json b/wfcommons/wfchef/recipes/rnaseq/task_type_stats.json
diff --git a/wfcommons/wfinstances/logs/nextflow.py b/wfcommons/wfinstances/logs/nextflow.py

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,7 @@ def run(self):`
`49`	`49`	`'genome_recipe = wfcommons.wfchef.recipes:GenomeRecipe',`
`50`	`50`	`'blast_recipe = wfcommons.wfchef.recipes:BlastRecipe',`
`51`	`51`	`'bwa_recipe = wfcommons.wfchef.recipes:BwaRecipe',`
	`52`	`+ 'rnaseq_recipe = wfcommons.wfchef.recipes:RnaseqRecipe',`
`52`	`53`	`]`
`53`	`54`	`},`
`54`	`55`	`)`