restructure python

.gitignore

@@ -8,6 +8,7 @@
 *.dll
 *.so
 *.dylib
+build/
 
 # Test binary, built with `go test -c`
 *.test

buf.gen.yaml

@@ -8,7 +8,7 @@ managed:
       - buf.build/bufbuild/protovalidate
 plugins:
   - plugin: buf.build/protocolbuffers/python:v28.2
-    out: modules/
+    out: pytask/
   - plugin: buf.build/connectrpc/go:v1.11.1
     out: pkg/gen/
     opt:

example/main.py

@@ -41,17 +41,3 @@ def hello_world_2(a : int, b : int) -> bool:
     return True
 
 
-@Workflow(WorkflowSpec(
-    name="hello_world",
-    description="This is a test workflow",
-    metadata={
-        "author": "Yuvraj Singh",
-        "version": "1.0.0",
-    },
-))
-def hello_world_workflow(a : int, b : int)-> bool:
-    return hello_world(a=a, b=b) or hello_world(a=a, b=b)
-
-
-if __name__ == "__main__":
-    hello_world()

idl/cloud/v1/cloud.proto

@@ -117,15 +117,6 @@ message Task {
     map<string, string> env = 14;
 }
 
-// Workflow represents a collection of tasks organized in a Directed Acyclic Graph (DAG).
-message Workflow {
-    string id = 1;          // Unique identifier for the workflow.
-    string name = 2;        // Name of the workflow.
-    string description = 3; // Description of the workflow.
-    repeated Task tasks = 4; // List of tasks in the workflow.
-    map<string, string> metadata = 5; // Additional metadata for the workflow.
-}
-
 // ExecutionStatus represents the current state of a task or workflow execution.
 enum ExecutionStatus {
     EXECUTION_STATUS_UNSPECIFIED = 0; // Status is not specified.
@@ -144,15 +135,6 @@ message TaskExecution {
     map<string, string> execution_metadata = 5; // Metadata related to the task execution.
 }
 
-// WorkflowExecution represents the execution of a workflow.
-message WorkflowExecution {
-    string workflow_id = 1;            // Unique identifier for the workflow being executed.
-    ExecutionStatus status = 2;        // Current execution status of the workflow.
-    repeated TaskExecution task_executions = 3; // List of task executions within the workflow.
-    google.protobuf.Timestamp created_at = 4; // Timestamp of when the workflow execution started.
-    google.protobuf.Timestamp updated_at = 5; // Timestamp of the last update to the workflow execution.
-    map<string, string> execution_metadata = 6; // Metadata related to the workflow execution.
-}
 
 // Message for Task history
 message TaskHistory {

pixi.toml

@@ -13,7 +13,7 @@ platforms = ["osx-64"]
 pre-commit = "~=3.3.0"
 
 git = "2.42.0.*"
-python = "=3.10"
+python = "=3.9"
 pip = "*"
 go = "=1.21"
 pyarrow = "14.0.2"