Method add_task_to_queue

app/data_source/api/base_data_source.py:127–131

(self, function: Callable, **kwargs)

            session.commit()

    def add_task_to_queue(self, function: Callable, **kwargs):
        task = Task(data_source_id=self._data_source_id,
                    function_name=function.__name__,
                    kwargs=kwargs)
        TaskQueue.get_instance().add_task(task)

    def run_task(self, function_name: str, **kwargs) -> None:
        self._last_task_time = get_utc_time_now()