DO NOT MERGE!: feat(spider-storage): Cache-layer prototyping.

components/spider-core/src/job.rs

@@ -27,6 +27,14 @@ impl JobState {
         matches!(self, Self::Succeeded | Self::Failed | Self::Cancelled)
     }
 
+    /// # Returns
+    ///
+    /// Whether the job is in [`JobState::Running`] state.
+    #[must_use]
+    pub const fn is_running(&self) -> bool {
+        matches!(self, Self::Running)
+    }
+
     /// # Returns
     ///
     /// Whether the state transition `from` -> `to` is valid.

components/spider-core/src/task.rs

@@ -1,6 +1,7 @@
 mod task_graph;
 mod type_descriptor;
 
+use serde::{Deserialize, Serialize};
 pub use task_graph::*;
 use thiserror::Error;
 pub use type_descriptor::*;
@@ -24,14 +25,41 @@ pub enum Error {
 }
 
 /// Enum for all possible states of a task.
+#[derive(Eq, PartialEq, Debug, Clone)]
 pub enum TaskState {
-    PENDING,
+    Pending,
     Ready,
     Running,
     Succeeded,
     Failed(String),
     Cancelled,
 }
 
+impl TaskState {
+    #[must_use]
+    pub const fn is_terminal(&self) -> bool {
+        matches!(self, Self::Succeeded | Self::Failed(_) | Self::Cancelled)
+    }
+}
+
 /// Represents metadata associated with a task.
 pub struct TaskMetadata {}
+
+/// Execution policy for a task, controlling concurrency and retry behavior.
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct ExecutionPolicy {
+    /// The maximum number of concurrent instances allowed for this task.
+    pub max_num_instances: usize,
+
+    /// The maximum number of retries allowed for this task on failure.
+    pub max_num_retries: usize,
+}
+
+impl Default for ExecutionPolicy {
+    fn default() -> Self {
+        Self {
+            max_num_instances: 1,
+            max_num_retries: 0,
+        }
+    }
+}