fix: the rest of the .aio.

Author: mrkaye97

examples/cron/programatic-async.py

@@ -5,7 +5,7 @@
 
 async def create_cron() -> None:
     # ❓ Create
-    cron_trigger = await hatchet.cron.aio.create(
+    cron_trigger = await hatchet.cron.aio_create(
         workflow_name="simple-cron-workflow",
         cron_name="customer-a-daily-report",
         expression="0 12 * * *",
@@ -21,13 +21,13 @@ async def create_cron() -> None:
     # !!
 
     # ❓ List
-    await hatchet.cron.aio.list()
+    await hatchet.cron.aio_list()
     # !!
 
     # ❓ Get
-    cron_trigger = await hatchet.cron.aio.get(cron_trigger=cron_trigger.metadata.id)
+    cron_trigger = await hatchet.cron.aio_get(cron_trigger=cron_trigger.metadata.id)
     # !!
 
     # ❓ Delete
-    await hatchet.cron.aio.delete(cron_trigger=cron_trigger.metadata.id)
+    await hatchet.cron.aio_delete(cron_trigger=cron_trigger.metadata.id)
     # !!

examples/scheduled/programatic-async.py

@@ -7,7 +7,7 @@
 
 async def create_scheduled() -> None:
     # ❓ Create
-    scheduled_run = await hatchet.scheduled.aio.create(
+    scheduled_run = await hatchet.scheduled.aio_create(
         workflow_name="simple-workflow",
         trigger_at=datetime.now() + timedelta(seconds=10),
         input={
@@ -22,13 +22,13 @@ async def create_scheduled() -> None:
     # !!
 
     # ❓ Delete
-    await hatchet.scheduled.aio.delete(scheduled=scheduled_run.metadata.id)
+    await hatchet.scheduled.aio_delete(scheduled=scheduled_run.metadata.id)
     # !!
 
     # ❓ List
-    await hatchet.scheduled.aio.list()
+    await hatchet.scheduled.aio_list()
     # !!
 
     # ❓ Get
-    scheduled_run = await hatchet.scheduled.aio.get(scheduled=scheduled_run.metadata.id)
+    scheduled_run = await hatchet.scheduled.aio_get(scheduled=scheduled_run.metadata.id)
     # !!

hatchet_sdk/features/cron.py

@@ -1,4 +1,4 @@
-from typing import Union
+from typing import List, Union
 
 from pydantic import BaseModel, Field, field_validator
 
@@ -81,7 +81,6 @@ def __init__(self, _client: Client):
             _client (Client): The client instance to be used for REST interactions.
         """
         self._client = _client
-        self.aio = CronClientAsync(_client)
 
     def create(
         self,
@@ -177,27 +176,7 @@ def get(self, cron_trigger: Union[str, CronWorkflows]) -> CronWorkflows:
             else cron_trigger
         )
 
-
-class CronClientAsync:
-    """
-    Asynchronous client for managing workflow cron triggers.
-
-    Attributes:
-        _client (Client): The underlying client used to interact with the REST API asynchronously.
-    """
-
-    _client: Client
-
-    def __init__(self, _client: Client):
-        """
-        Initializes the CronClientAsync with a given Client instance.
-
-        Args:
-            _client (Client): The client instance to be used for asynchronous REST interactions.
-        """
-        self._client = _client
-
-    async def create(
+    async def aio_create(
         self,
         workflow_name: str,
         cron_name: str,
@@ -230,7 +209,7 @@ async def create(
             additional_metadata=validated_input.additional_metadata,
         )
 
-    async def delete(self, cron_trigger: Union[str, CronWorkflows]) -> None:
+    async def aio_delete(self, cron_trigger: Union[str, CronWorkflows]) -> None:
         """
         Asynchronously deletes a workflow cron trigger.
 
@@ -243,12 +222,12 @@ async def delete(self, cron_trigger: Union[str, CronWorkflows]) -> None:
             else cron_trigger
         )
 
-    async def list(
+    async def aio_list(
         self,
         offset: int | None = None,
         limit: int | None = None,
         workflow_id: str | None = None,
-        additional_metadata: list[str] | None = None,
+        additional_metadata: List[str] | None = None,
         order_by_field: CronWorkflowsOrderByField | None = None,
         order_by_direction: WorkflowRunOrderByDirection | None = None,
     ) -> CronWorkflowsList:
@@ -275,7 +254,7 @@ async def list(
             order_by_direction=order_by_direction,
         )
 
-    async def get(self, cron_trigger: Union[str, CronWorkflows]) -> CronWorkflows:
+    async def aio_get(self, cron_trigger: Union[str, CronWorkflows]) -> CronWorkflows:
         """
         Asynchronously retrieves a specific workflow cron trigger by ID.
 

hatchet_sdk/features/scheduled.py

@@ -54,7 +54,6 @@ def __init__(self, _client: Client) -> None:
             _client (Client): The client instance to be used for REST interactions.
         """
         self._client = _client
-        self.aio: "ScheduledClientAsync" = ScheduledClientAsync(_client)
 
     def create(
         self,
@@ -148,27 +147,7 @@ def get(self, scheduled: Union[str, ScheduledWorkflows]) -> ScheduledWorkflows:
             else scheduled
         )
 
-
-class ScheduledClientAsync:
-    """
-    Asynchronous client for managing scheduled workflows.
-
-    Attributes:
-        _client (Client): The underlying client used to interact with the REST API asynchronously.
-    """
-
-    _client: Client
-
-    def __init__(self, _client: Client) -> None:
-        """
-        Initializes the ScheduledClientAsync with a given Client instance.
-
-        Args:
-            _client (Client): The client instance to be used for asynchronous REST interactions.
-        """
-        self._client = _client
-
-    async def create(
+    async def aio_create(
         self,
         workflow_name: str,
         trigger_at: datetime.datetime,
@@ -191,7 +170,7 @@ async def create(
             workflow_name, trigger_at, input, additional_metadata
         )
 
-    async def delete(self, scheduled: Union[str, ScheduledWorkflows]) -> None:
+    async def aio_delete(self, scheduled: Union[str, ScheduledWorkflows]) -> None:
         """
         Deletes a scheduled workflow asynchronously.
 
@@ -204,7 +183,7 @@ async def delete(self, scheduled: Union[str, ScheduledWorkflows]) -> None:
             else scheduled
         )
 
-    async def list(
+    async def aio_list(
         self,
         offset: int | None = None,
         limit: int | None = None,
@@ -236,7 +215,7 @@ async def list(
             order_by_direction=order_by_direction,
         )
 
-    async def get(
+    async def aio_get(
         self, scheduled: Union[str, ScheduledWorkflows]
     ) -> ScheduledWorkflows:
         """