def shard_init (self, *args, **kwargs):
        worker = args[0]
        payload, start_response, body = worker.get_response_context(args[1:])

        if worker.auth_request(payload, start_response, body):
            self.set_ring(worker.shard_id, worker.ring)
            worker.prep_task_queue()

            start_response('200 OK', [('Content-Type', 'text/plain')])
            body.put("Bokay\r\n")
            body.put(StopIteration)
initialize a shard
dataset/ETHPy150Open ceteri/exelixi/src/contain.py/ContainerUOW.shard_init