Converted updatable_timer to a module

Author: mfateev

updatable_timer/__init__.py

@@ -0,0 +1 @@
+TASK_QUEUE = "updatable-timer"

updatable_timer/starter.py

@@ -6,7 +6,8 @@
 from temporalio import exceptions
 from temporalio.client import Client
 
-from workflow import Workflow
+from updatable_timer import TASK_QUEUE
+from updatable_timer.workflow import Workflow
 
 
 async def main(client: Optional[Client] = None):
@@ -18,7 +19,7 @@ async def main(client: Optional[Client] = None):
             Workflow.run,
             (datetime.now() + timedelta(days=1)).timestamp(),
             id=f"updatable-timer-workflow",
-            task_queue="updatable-timer",
+            task_queue=TASK_QUEUE,
         )
         logging.info(f"Workflow started: run_id={handle.result_run_id}")
     except exceptions.WorkflowAlreadyStartedError as e:

updatable_timer/updatable_timer.py updatable_timer/updatable_timer_lib.pyupdatable_timer/updatable_timer.py renamed to updatable_timer/updatable_timer_lib.py

@@ -5,7 +5,7 @@
 
 from temporalio.client import Client
 
-from workflow import Workflow
+from updatable_timer.workflow import Workflow
 
 
 async def main(client: Optional[Client] = None):

updatable_timer/wake_up_time_updater.py

@@ -3,7 +3,9 @@
 
 from temporalio.client import Client
 from temporalio.worker import Worker
-from workflow import Workflow
+
+from updatable_timer import TASK_QUEUE
+from updatable_timer.workflow import Workflow
 
 interrupt_event = asyncio.Event()
 
@@ -14,7 +16,7 @@ async def main():
     client = await Client.connect("localhost:7233")
     async with Worker(
             client,
-            task_queue="updatable-timer",
+            task_queue=TASK_QUEUE,
             workflows=[Workflow],
     ):
         logging.info("Worker started, ctrl+c to exit")

updatable_timer/worker.py

@@ -2,7 +2,7 @@
 
 from temporalio import workflow
 
-from updatable_timer import UpdatableTimer
+from updatable_timer.updatable_timer_lib import UpdatableTimer
 
 
 @workflow.defn
@@ -18,9 +18,9 @@ async def run(self, wake_up_time: float):
 
     @workflow.signal
     async def update_wake_up_time(self, wake_up_time: float):
-        # Deals with situation when signal method is called before run method.
-        # This happens when workflow task is executed after the signal is received
-        # or when workflow is started using signal with start.
+        # Deals with situation when the signal method is called before the run method.
+        # This happens when a workflow task is executed after a signal is received
+        # or when a workflow is started using the signal-with-start.
         await workflow.wait_condition(lambda: self.timer is not None)
         self.timer.update_wake_up_time(datetime.fromtimestamp(wake_up_time, tz=timezone.utc))