Functions¶

flowtask.scheduler.functions ¶

TaskScheduler(program, task, job_id, priority='low', worker=None, **kwargs)

import_from_path(path)

Import a module / class from a path string. :param str path: class path, e.g., ndscheduler.corescheduler.job :return: class object :rtype: class