def _send_start_ok(self, client_properties, mechanism, response, locale):
        if self.server_capabilities.get('consumer_cancel_notify'):
            if 'capabilities' not in client_properties:
                client_properties['capabilities'] = {}
            client_properties['capabilities']['consumer_cancel_notify'] = True
        if self.server_capabilities.get('connection.blocked'):
            if 'capabilities' not in client_properties:
                client_properties['capabilities'] = {}
            client_properties['capabilities']['connection.blocked'] = True
        args = AMQPWriter()
        args.write_table(client_properties)
        args.write_shortstr(mechanism)
        args.write_longstr(response)
        args.write_shortstr(locale)
        self._send_method(Method(spec.Connection.StartOk, args))
Restart Celery and Celerybeat
dataset/ETHPy150Open veegee/amqpy/amqpy/connection.py/Connection._send_start_ok--crossover with--dataset/ETHPy150Open onefinestay/gonzo/gonzo/tasks/celery.py/restart