jobs

jobs module

class jobs.JobStatus(value)

Bases: Enum

COMPLETED = 5

CORRUPTED = 4

FAILED = 2

INVALID = 3

PENDING = 1

get_label()

class jobs.SerieStationData(station_code: int, start_date: sqlalchemy.sql.sqltypes.DateTime, end_date: sqlalchemy.sql.sqltypes.DateTime)

Bases: object

end_date : DateTime

start_date : DateTime

station_code : int

jobs.check_resource(resource: HidroResource) → None

jobs.check_series_job(job_config: JobConfig) → None

jobs.check_stations_jobs() → None

jobs.create_series_jobs(stations_data: List[SerieStationData], job_config: JobConfig) → None

jobs.data_to_model_orm(job_config: JobConfig, hidro_data: dict)

jobs.db_writer() → None

jobs.get_queue_data_size(data)

jobs.get_token() → str

Authenticate and return access token. Returns: Valid token for requesition

jobs.handle_job(job: HidroJob, job_config: JobConfig) → None

jobs.trigger_job(job_config: JobConfig) → None

jobs.validate_data(job_config: JobConfig, items: dict, job: HidroJob'>, <class 'dict'>)

jobs.write_data(job_config: JobConfig, jobs: List[HidroJob], hidro_data: dict) → float