Skip to content

GitLab

"...ssh:/git@developer.sourcefind.cn:2222/OpenDAS/dynamo.git" did not exist on "ab9c9509f407fb913058679ccfbefdc39ee72fc8"
Unverified Commit edc6fdea authored by Kris Hung's avatar Kris Hung Committed by GitHub
Browse files

fix: Fix async_on_start syntax (#1243)

parent 1b1e089a
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
examples/multimodal/components/encode_worker.py
View file @ edc6fdea
...@@ -148,8 +148,8 @@ class VllmEncodeWorker: ...@@ -148,8 +148,8 @@ class VllmEncodeWorker:
request_id=request.request_id, request_id=request.request_id,
).model_dump_json() ).model_dump_json()
@async_on_start() @async_on_start
async def on_start(self): async def async_init(self):
logger.info("Startup started.") logger.info("Startup started.")
# Create and initialize a dynamo connector for this worker. # Create and initialize a dynamo connector for this worker.
# We'll needs this to move data between this worker and remote workers efficiently. # We'll needs this to move data between this worker and remote workers efficiently.
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment