def execute(self, item, context):
        try:
            obj, action = item
        except __HOLE__:
            self.logger.exception('Error executing on item: {0}'.format(item))
            return
        try:
            func = getattr(self.sqlite_manager, action)
        except AttributeError:
            self.logger.exception(
                'unable to run action, {0}, no such method'.format(action)
            )
            raise
        try:
            if isinstance(obj, tuple):
                func(*obj)
            else:
                func(obj)
        except OperationalError:
            self.logger.exception("Unsupported operation")
            return
dataset/ETHPy150Open facebook/augmented-traffic-control/atc/atcd/atcd/AtcdDBQueueTask.py/AtcdDBQueueTask.execute