refactor: rename to drive-flow

gusye1234 · gusye1234 · commit 97ce8e68e29d · 2024-09-12T00:06:14.000+08:00
diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml
@@ -43,7 +43,7 @@ jobs:
           flake8 . --count --select=E9,F63,F7,F82 --show-source --statistics
       - name: Build and Test
         run: |
-          python -m pytest -o log_cli=true -o log_cli_level="INFO" --cov=drive_events --cov-report=xml -v ./
+          python -m pytest -o log_cli=true -o log_cli_level="INFO" --cov=drive_flow --cov-report=xml -v ./
       - name: Check codecov file
         id: check_files
         uses: andstor/file-existence-action@v1
diff --git a/drive_flow/__init__.py b/drive_flow/__init__.py
@@ -3,6 +3,6 @@
 
 __version__ = "0.0.1.alpha1"
 __author__ = "Jianbai Ye"
-__url__ = "https://github.com/memodb-io/drive-events"
+__url__ = "https://github.com/memodb-io/drive-flow"
 
 default_drive = EventEngineCls()
diff --git a/drive_flow/broker.py b/drive_flow/broker.py
diff --git a/drive_flow/core.py b/drive_flow/core.py
diff --git a/drive_flow/dynamic.py b/drive_flow/dynamic.py
diff --git a/drive_flow/types.py b/drive_flow/types.py
diff --git a/drive_flow/utils.py b/drive_flow/utils.py
@@ -5,7 +5,7 @@
 import hashlib
 from typing import Callable
 
-logger = logging.getLogger("drive-events")
+logger = logging.getLogger("drive-flow")
 
 
 def generate_uuid() -> str:
diff --git a/examples/1_hello_world_in_order.py b/examples/1_hello_world_in_order.py
@@ -1,5 +1,5 @@
 import asyncio
-from drive_events import EventInput, default_drive
+from drive_flow import EventInput, default_drive
 
 
 @default_drive.make_event
diff --git a/examples/2_hello_world_parallele.py b/examples/2_hello_world_parallele.py
@@ -1,6 +1,6 @@
 import asyncio
 from datetime import datetime
-from drive_events import EventInput, default_drive
+from drive_flow import EventInput, default_drive
 
 
 @default_drive.make_event
diff --git a/examples/3_use_event_output.py b/examples/3_use_event_output.py
@@ -1,6 +1,6 @@
 import asyncio
 from datetime import datetime
-from drive_events import EventInput, default_drive
+from drive_flow import EventInput, default_drive
 
 
 @default_drive.make_event
diff --git a/examples/4_endless_tick_timer.py b/examples/4_endless_tick_timer.py
@@ -1,7 +1,7 @@
 import asyncio
 from datetime import datetime
-from drive_events import default_drive, EventInput
-from drive_events.dynamic import goto_events
+from drive_flow import default_drive, EventInput
+from drive_flow.dynamic import goto_events
 
 
 @default_drive.make_event
diff --git a/readme.md b/readme.md
@@ -1,15 +1,15 @@
 <div align="center">
-  <h1>drive-events</h1>
+  <h1>drive-flow</h1>
   <p><strong>Build event-driven workflows with python async functions</strong></p>
   <p>
-    <a href="https://pypi.org/project/drive-events/" > 
+    <a href="https://pypi.org/project/drive-flow/" > 
     	<img src="https://img.shields.io/badge/python->=3.9.11-blue">
     </a>
-    <a href="https://codecov.io/github/memodb-io/drive-events" > 
-     <img src="https://codecov.io/github/memodb-io/drive-events/graph/badge.svg?token=T1Q1JB1NGM"/> 
+    <a href="https://codecov.io/github/memodb-io/drive-flow" > 
+     <img src="https://codecov.io/github/memodb-io/drive-flow/graph/badge.svg?token=T1Q1JB1NGM"/> 
 	 </a>
-    <a href="https://pypi.org/project/drive-events/">
-      <img src="https://img.shields.io/pypi/v/drive-events.svg">
+    <a href="https://pypi.org/project/drive-flow/">
+      <img src="https://img.shields.io/pypi/v/drive-flow.svg">
     </a>
   </p>
 </div>
@@ -28,14 +28,14 @@
 **Install from PyPi**
 
 ```shell
-pip install drive-events
+pip install drive-flow
 ```
 
 **Install from source**
 
 ```shell
 # clone this repo first
-cd drive-events
+cd drive-flow
 pip install -e .
 ```
 
@@ -47,7 +47,7 @@ A hello world example:
 
 ```python
 import asyncio
-from drive_events import EventInput, default_drive
+from drive_flow import EventInput, default_drive
 
 
 @default_drive.make_event
@@ -82,7 +82,7 @@ Check out [examples](./examples) for more user cases!
 
 ### Multi-Recv
 
-`drive_events` allow an event to be triggered only when a group of events are produced:
+`drive_flow` allow an event to be triggered only when a group of events are produced:
 
 <details>
 <summary> code snippet</summary>
@@ -118,7 +118,7 @@ assert results[adding.id] == 3
 
 ### Parallel
 
-`drive_events` is perfect for workflows that have many network IO that can be awaited in parallel. If two events are listened to the same group of events, then they will be triggered at the same time:
+`drive_flow` is perfect for workflows that have many network IO that can be awaited in parallel. If two events are listened to the same group of events, then they will be triggered at the same time:
 
 <details>
 <summary> code snippet</summary>
@@ -151,13 +151,13 @@ asyncio.run(default_drive.invoke_event(start))
 
 ### Dynamic
 
-`drive_events` is dynamic. You can use `goto` and `abort` to change the workflow at runtime:
+`drive_flow` is dynamic. You can use `goto` and `abort` to change the workflow at runtime:
 
 <details>
 <summary> code snippet for abort</summary>
 
 ```python
-from drive_events.dynamic import abort_this
+from drive_flow.dynamic import abort_this
 
 @default_drive.make_event
 async def a(event: EventInput, global_ctx):
@@ -176,8 +176,8 @@ asyncio.run(default_drive.invoke_event(a))
 <summary> code snippet for goto</summary>
 
 ```python
-from drive_events.types import ReturnBehavior
-from drive_events.dynamic import goto_events, abort_this
+from drive_flow.types import ReturnBehavior
+from drive_flow.dynamic import goto_events, abort_this
 
 call_a_count = 0
 @default_drive.make_event
diff --git a/setup.py b/setup.py
@@ -6,7 +6,7 @@
 
 vars2find = ["__author__", "__version__", "__url__"]
 vars2readme = {}
-with open("./drive_events/__init__.py") as f:
+with open("./drive_flow/__init__.py") as f:
     for line in f.readlines():
         for v in vars2find:
             if line.startswith(v):
@@ -21,14 +21,14 @@
         deps.append(line.strip())
 
 setuptools.setup(
-    name="drive-events",
+    name="drive-flow",
     url=vars2readme["__url__"],
     version=vars2readme["__version__"],
     author=vars2readme["__author__"],
     description="Build event-driven workflows with python functions",
     long_description=long_description,
     long_description_content_type="text/markdown",
-    packages=["drive_events"],
+    packages=["drive_flow"],
     classifiers=[
         "Programming Language :: Python :: 3",
         "License :: OSI Approved :: MIT License",
diff --git a/tests/test_define.py b/tests/test_define.py
@@ -1,7 +1,7 @@
 import pytest
 
-from drive_events import default_drive, EventInput
-from drive_events.types import BaseEvent
+from drive_flow import default_drive, EventInput
+from drive_flow.types import BaseEvent
 
 
 @pytest.mark.asyncio
diff --git a/tests/test_dynamic_run.py b/tests/test_dynamic_run.py
@@ -1,7 +1,7 @@
 import pytest
-from drive_events import default_drive, EventInput
-from drive_events.types import ReturnBehavior, _SpecialEventReturn
-from drive_events.dynamic import goto_events, abort_this
+from drive_flow import default_drive, EventInput
+from drive_flow.types import ReturnBehavior, _SpecialEventReturn
+from drive_flow.dynamic import goto_events, abort_this
 
 
 class DeliberateExcepion(Exception):
diff --git a/tests/test_run.py b/tests/test_run.py
@@ -1,6 +1,6 @@
 import pytest
-from drive_events import default_drive, EventInput
-from drive_events.types import ReturnBehavior
+from drive_flow import default_drive, EventInput
+from drive_flow.types import ReturnBehavior
 
 
 class DeliberateExcepion(Exception):
diff --git a/tests/test_types.py b/tests/test_types.py
@@ -1,4 +1,4 @@
-from drive_events.types import BaseEvent, EventGroup
+from drive_flow.types import BaseEvent, EventGroup
 
 
 def test_node_hash():
diff --git a/tests/test_utils.py b/tests/test_utils.py
@@ -1,5 +1,5 @@
 import pytest
-from drive_events import utils
+from drive_flow import utils
 
 
 def test_func_to_string():
