Removed robyn dependency

* Update python matrix

* Fix robyn depency

* Fix multiprocess import

* ASGI run arg fix

* Added worker kwargs

* Add grpcio to pyproject.toml

* Lint fixes

* Bump pydantic up to ^2.10.0

* Lock file update

* fix: apply code style improvements and typing enhancements (#29)

Co-authored-by: Dmitriy Astapkovich <[email protected]>

* Replace robyn dep to seperate group

* Set straight dependency for st and wheel

* Remove robyn

* Ignoring robyn dependency

---------

Co-authored-by: Dmitriy Astapkovich <[email protected]>
Co-authored-by: Dmitriy Astapkovich <[email protected]>

Author: 3 people

.github/workflows/ci_prepare.yml

@@ -12,7 +12,7 @@ jobs:
         timeout-minutes: 30
         strategy:
             matrix:
-                python-version: ["3.10", "3.11"]
+                python-version: ["3.10", "3.11", "3.12", "3.13"]
 
         steps:
             - uses: actions/checkout@v3
@@ -35,7 +35,7 @@ jobs:
         timeout-minutes: 30
         strategy:
             matrix:
-                python-version: ["3.10", "3.11"]
+                python-version: ["3.10", "3.11", "3.12", "3.13"]
         steps:
             - uses: actions/checkout@v3
             - name: Set up Python ${{ matrix.python-version }}

.vscode/settings.json

@@ -11,4 +11,4 @@
     "python.analysis.extraPaths": [
         "./temporal_boost"
     ]
-}
+}

README.md

@@ -56,7 +56,7 @@ class TestCronWorkflow:
 
 app.add_worker(
     "worker_1",
-    "task_q_1", 
+    "task_q_1",
     activities=[test_boost_activity_1],
     metrics_endpoint="0.0.0.0:9000"
 )
@@ -81,7 +81,7 @@ app.run()
 ```
 
 ```bash
-python3 main.py 
+python3 main.py
 
 # Usage: main.py [OPTIONS] COMMAND [ARGS]...
 
@@ -122,4 +122,4 @@ python3 main.py run worker_1
 # 2023-09-20T21:25:12 | INFO     | Worker test_cron was registered in CLI
 # 2023-09-20T21:25:12 | INFO     | Worker worker_1 started on task_q_1 queue
 
-```
+```

docs/creating_application.md

@@ -18,7 +18,7 @@ app: BoostApp = BoostApp(
         bind_extra={"foo": "bar",},
         level="DEBUG",
         multiprocess_safe=True
-    ),    
+    ),
     otlp_config=BoostOTLPConfig(
         otlp_endpoint="otlp-collector",
         service_name="example-app"
@@ -153,7 +153,7 @@ app.add_worker(
 
 Now, internal worker can be used for autogenerated documentation for Temporal objects
 
-In future, opportunities of this object will be expanded 
+In future, opportunities of this object will be expanded
 
 ```python
 app.add_internal_worker("0.0.0.0", 8888, doc_endpoint="/doc")
@@ -181,4 +181,4 @@ Now, you can add it to Temporal-boost application:
 app.add_asgi_worker("asgi_worker", fastapi_app, "0.0.0.0", 8000)
 ```
 
-This application will be executed with [Hypercorn](https://github.com/pgjones/hypercorn) + [Trio](https://github.com/python-trio/trio) in asyncio runtime
+This application will be executed with [Hypercorn](https://github.com/pgjones/hypercorn) + [Trio](https://github.com/python-trio/trio) in asyncio runtime

docs/index.md

@@ -50,7 +50,7 @@ from temporal_boost import BoostApp, BoostLoggerConfig
 app: BoostApp = BoostApp(
     logger_config=BoostLoggerConfig(
         json=True,
-        bind_extra={"logging_extra_data": "foo_bar"}, 
+        bind_extra={"logging_extra_data": "foo_bar"},
         level="DEBUG"),
     use_pydantic=True,
 )
@@ -103,4 +103,4 @@ Starting workers one by one
 ```bash
 python3 main.py run worker_1
 python3 main.py run worker_2
-```
+```

docs/runnig_application.md

@@ -56,4 +56,4 @@ To run cron worker, use this command:
 
 ```bash
 python3 main.py cron worker_4
-```
+```

examples/example_app.py

@@ -21,22 +21,25 @@
     name="BoostApp example",
     temporal_endpoint="localhost:7233",
     temporal_namespace="default",
-    otlp_config=BoostOTLPConfig(otlp_endpoint="otlp-collector", service_name="example-app")
+    otlp_config=BoostOTLPConfig(otlp_endpoint="otlp-collector", service_name="example-app"),
 )
 
+
 @dataclass
 class TestModel:
     foo: str
     bar: int
     spam: int = 3
     eggs: bool | None = None
 
+
 def fake_db_migration():
     """
-        Fake fn for db migrations
+    Fake fn for db migrations
     """
     print("fake")
 
+
 # Describe your activities/workflows
 @activity.defn(name="test_boost_activity_1")
 async def test_boost_activity_1(payload: TestModel) -> TestModel:
@@ -93,19 +96,20 @@ async def my_signal(self, signal_arg: TestModel):
         print(signal_arg)
 
 
-
-
 class TestAsyncRuntime:
     """
-        Class must implement `run` method
+    Class must implement `run` method
     """
+
     async def _test_async_runtime(self):
         while True:
             print(random.random())
             await asyncio.sleep(1)
+
     def run(self):
         asyncio.run(self._test_async_runtime())
 
+
 # Add async workers to your app
 if __name__ == "__main__":
     app.add_worker(
@@ -119,14 +123,17 @@ def run(self):
 
     app.add_worker("worker_3", "task_q_3", workflows=[MyWorkflow])
 
-    #app.add_worker("worker_4", "task_q_4", workflows=[MyWorkflow], cron_runner=MyWorkflow.run, cron_schedule="* * * * *")
+    # app.add_worker("worker_4", "task_q_4", workflows=[MyWorkflow], cron_runner=MyWorkflow.run, cron_schedule="* * * * *")
 
     app.add_asgi_worker("asgi_worker", fastapi_app, "0.0.0.0", 8001)
-
-    app.add_internal_worker("0.0.0.0", 8888, doc_endpoint="/doc")
+    """
+        Internal worker is not supported for Pyhton3.13 yet
+        To use it, install `robyn` first
+    """
+    # app.add_internal_worker("0.0.0.0", 8998, doc_endpoint="/doc")
 
     app.add_exec_method_sync("migrate_db", fake_db_migration)
 
-    app.add_async_runtime("test_async", runtime=TestAsyncRuntime())
+    # app.add_async_runtime("test_async", runtime=TestAsyncRuntime())
     # Run your app and start workers with CLI
     app.run()

mkdocs.yml

@@ -12,7 +12,7 @@ theme:
   - navigation.tracking
   - content.code.copy
   icon:
-    annotation: material/arrow-right-circle 
+    annotation: material/arrow-right-circle
 
 
 plugins:
@@ -38,4 +38,4 @@ markdown_extensions:
 nav:
   - Getting started: index.md
   - Creating application: creating_application.md
-  - Running application: runnig_application.md
+  - Running application: runnig_application.md