Module pipelines.utils

Helper flows that could fit any pipeline.

Expand source code
# -*- coding: utf-8 -*-
"""
Helper flows that could fit any pipeline.
"""
from pipelines.utils.backfill_flow.flows import *
from pipelines.utils.dump_datario.flows import *
from pipelines.utils.dump_db.flows import *
from pipelines.utils.dump_earth_engine_asset.flows import *
from pipelines.utils.dump_to_gcs.flows import *
from pipelines.utils.dump_url.flows import *
from pipelines.utils.execute_dbt_model.flows import *
from pipelines.utils.georeference.flows import *
from pipelines.utils.predict_flow.flows import *
from pipelines.utils.whatsapp_bot.flows import *

Sub-modules

pipelines.utils.backfill_flow
pipelines.utils.constants

Constants for utils.

pipelines.utils.custom

Customizing stuff for the pipelines package.

pipelines.utils.decorators

Custom decorators for pipelines.

pipelines.utils.dump_datario
pipelines.utils.dump_db
pipelines.utils.dump_earth_engine_asset
pipelines.utils.dump_to_gcs
pipelines.utils.dump_url
pipelines.utils.elasticsearch_metrics
pipelines.utils.execute_dbt_model

" Init file for execute_dbt_model module

pipelines.utils.ftp
pipelines.utils.georeference
pipelines.utils.policy_matrix
pipelines.utils.predict_flow

" Init file for predict_flow module

pipelines.utils.tasks

Helper tasks that could fit any pipeline.

pipelines.utils.utils

General utilities for all pipelines.

pipelines.utils.whatsapp_bot