fix: get rid of impl

Author: mrkaye97

examples/simple/worker.py

@@ -1,14 +1,14 @@
 from dotenv import load_dotenv
 
 from hatchet_sdk import Context
-from hatchet_sdk.v2 import BaseWorkflowImpl, Hatchet
+from hatchet_sdk.v2 import BaseWorkflow, Hatchet
 
 load_dotenv()
 
 hatchet = Hatchet(debug=True)
 
 
-class MyWorkflow(BaseWorkflowImpl):
+class MyWorkflow(BaseWorkflow):
     @hatchet.step(timeout="11s", retries=3)
     def step1(self, context: Context) -> dict[str, str]:
         print("executed step1")

examples/v2/worker.py

@@ -1,9 +1,9 @@
 from examples.v2.workflows import example_workflow, hatchet
 from hatchet_sdk import Context
-from hatchet_sdk.v2 import BaseWorkflowImpl
+from hatchet_sdk.v2 import BaseWorkflow
 
 
-class ExampleV2Workflow(BaseWorkflowImpl):
+class ExampleV2Workflow(BaseWorkflow):
     config = example_workflow.config
 
     @hatchet.step(timeout="11s", retries=3)

hatchet_sdk/v2/__init__.py

@@ -1,3 +1,3 @@
 from .hatchet import Hatchet as Hatchet
-from .workflows import BaseWorkflowImpl as BaseWorkflowImpl
+from .workflows import BaseWorkflow as BaseWorkflow
 from .workflows import WorkflowConfig as WorkflowConfig

hatchet_sdk/v2/workflows.py

@@ -146,7 +146,7 @@ def __init__(
 class RegisteredStep(Step[R]):
     def __init__(
         self,
-        workflow: "BaseWorkflowImpl",
+        workflow: "BaseWorkflow",
         step: Step[R],
     ) -> None:
         self.workflow = workflow
@@ -193,7 +193,7 @@ def workflow_input(self, ctx: Context) -> TWorkflowInput:
         return cast(TWorkflowInput, ctx.workflow_input())
 
 
-class BaseWorkflowImpl:
+class BaseWorkflow:
     """
     A Hatchet workflow implementation base. This class should be inherited by all workflow implementations.
 

hatchet_sdk/worker/worker.py

@@ -36,7 +36,7 @@
 )
 
 if TYPE_CHECKING:
-    from hatchet_sdk.v2 import BaseWorkflowImpl
+    from hatchet_sdk.v2 import BaseWorkflow
 
 T = TypeVar("T")
 
@@ -110,7 +110,7 @@ def register_workflow_from_opts(
             logger.error(e)
             sys.exit(1)
 
-    def register_workflow(self, workflow: Union["BaseWorkflowImpl", Any]) -> None:
+    def register_workflow(self, workflow: Union["BaseWorkflow", Any]) -> None:
         namespace = self.client.config.namespace
 
         try: