Module pipelines.rj_cor.tasks

Common Tasks for rj-cor

Functions

def get_on_redis(dataset_id: str, table_id: str, mode: str = 'prod', wait=None) ‑> list

Get filenames saved on Redis.

def save_on_redis(dataset_id: str, table_id: str, mode: str = 'prod', files: list = [], keep_last: int = 50, wait=None) ‑> None

Set the last updated time on Redis.