- if task["status"] == "SCHEDULED" or task["action"] == "CREATE" or task["action"] == "FIND":
- task_list.append(task)
- elif task["action"] == "DELETE":
- # action completed because deleted and status is not SCHEDULED. Not needed anything
- action_completed = True
- if len(vim_actions) == database_limit:
- # update variables for get the next database iteration
- old_item_id = item_id
- old_item = item
- old_created_at = task["created_at"]
- else:
- break
- # Last actions group need to be inserted too
- if not action_completed and task_list:
- self._insert_pending_tasks(task_list)
- self.logger.debug("reloaded vim actions pending:{} refresh:{}".format(
- len(self.pending_tasks), len(self.refresh_tasks)))
+ if task["status"] == "SCHEDULED" or task["action"] == "CREATE" or task["action"] == "FIND":
+ task_list.append(task)
+ elif task["action"] == "DELETE":
+ # action completed because deleted and status is not SCHEDULED. Not needed anything
+ action_completed = True
+ if len(vim_actions) == database_limit:
+ # update variables for get the next database iteration
+ old_item_id = item_id
+ old_item = item
+ old_created_at = task["created_at"]
+ else:
+ break
+ # Last actions group need to be inserted too
+ if not action_completed and task_list:
+ try:
+ self._insert_pending_tasks(task_list)
+ except Exception as e:
+ self.logger.critical("Unexpected exception at _reload_vim_actions:_insert_pending_tasks: " + str(e),
+ exc_info=True)
+ self.logger.debug("reloaded vim actions pending:{} refresh:{}".format(
+ len(self.pending_tasks), len(self.refresh_tasks)))
+ except Exception as e:
+ self.logger.critical("Unexpected exception at _reload_vim_actions: " + str(e), exc_info=True)