We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6e6e386 commit b8bc0c9Copy full SHA for b8bc0c9
rayvens/api.py
@@ -31,7 +31,7 @@
31
class Stream:
32
def __init__(self,
33
name,
34
- actor_options=None,
+ actor_options={},
35
operator=None,
36
source_config=None,
37
sink_config=None,
@@ -40,7 +40,7 @@ def __init__(self,
40
raise RuntimeError(
41
"Rayvens has not been started. Start with 'rayvens.init()'.")
42
self.name = name
43
- self.actor = StreamActor.options(actor_options).remote(
+ self.actor = StreamActor.options(*actor_options).remote(
44
name, operator=operator, batch_size=batch_size)
45
if sink_config is not None:
46
self.add_sink(sink_config)
0 commit comments