feat(dask): check if dask is required for the workflow (reanahub#238)

Alputer · Aug 28, 2024 · 3e8e475 · 3e8e475
1 parent 67a7254
commit 3e8e475
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/reana_db/models.py b/reana_db/models.py
@@ -707,6 +707,12 @@ def workspace_has_pending_retention_rules(self):
         )
         return pending_rules.first() is not None
 
+    def requires_dask(self):
+        """Check whether Dask is necessary to run the workflow."""
+        return (
+            self.reana_specification["workflow"].get("resources", {}).get("dask", False)
+        )
+
     def get_priority(self, cluster_memory):
         """Workflow priority when scheduling it.