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)