Contents

from bytewax.swarm import register_bee

@register_bee(name = "hello")
def hello(swarm, payload, context):
    print("hello {}".format(payload['name']))
    swarm.publish(payload,context=context)

@register_bee(name = "goodbye")
def goodbye(swarm, payload, context):
    swarm.respond("goodbye {}".format(payload['name']), context = context)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
bytewax-docs-0.1.1	tutorials/hello-world/hello.py
bytewax-docs-0.1.0	tutorials/hello-world/hello.py