Module pipelines.utils.dump_datario.utils

General utilities for interacting with datario-dump

Functions

def generate_dump_datario_schedules(interval: datetime.timedelta, start_date: datetime.datetime, labels: List[str], table_parameters: dict, runs_interval_minutes: int = 15) ‑> List[prefect.schedules.clocks.IntervalClock]

Generates multiple schedules for dumping datario tables.

def load_wkt(x)

Fromt text to geometry

def remove_third_dimension(geom)

Remove third dimension from geometry