wehub-resource-sync
16 lines
226 B
Python
16 lines
226 B
Python
import os
|
|
|
|
import ray
|
|
from ray import serve
|
|
|
|
|
|
@serve.deployment
|
|
class A:
|
|
async def __call__(self):
|
|
signal = ray.get_actor("signal123")
|
|
await signal.wait.remote()
|
|
return os.getpid()
|
|
|
|
|
|
app = A.bind()
|