DatafileJob
DashAI.back.job.DatafileJob
Job that fetches a dataset file from an external hub source.
Parameters
kwargs : dict
- datafile_id: int (DB row id)
- source_name: str (DatasetSource class name)
- dataset_source_id: str (source-specific dataset identifier)
Methods
get_job_name(self) -> str
DatafileJobGet a descriptive name for the job.
run(self) -> None
DatafileJobRun the job.
set_status_as_delivered(self, session_factory: 'sessionmaker' = <function DatafileJob.<lambda> at 0x7f26c41fe3b0>) -> None
DatafileJobNo-op: datafile downloads don't use the delivered state.
set_status_as_error(self, session_factory: 'sessionmaker' = <function DatafileJob.<lambda> at 0x7f26c41fe4d0>) -> None
DatafileJobSet the status of the job as error.
report_progress(self, fraction: Optional[float], message: Optional[str] = None) -> None
BaseJobReport the job's progress to the job queue.
Parameters
- fraction: Optional float
- Completion in the range 0-1, or None when the total work is unknown (the frontend then shows an indeterminate bar).
- message: Optional str
- Short description of the current phase.