app package

Subpackages

• app.core package
  • Subpackages
    • app.core.celery package
      • Submodules
      • app.core.celery.app module
      • app.core.celery.celeryconfig module
      • Module contents
  • Submodules
  • app.core.dvc_client module
    • DVCClient
      • DVCClient.__init__()
      • DVCClient.read_data_from()
      • DVCClient.save_data_to()
  • Module contents
• app.tasks package
  • Subpackages
    • app.tasks.data_processing package
      • Submodules
      • app.tasks.data_processing.tasks module
      • Module contents
    • app.tasks.data_transformation package
      • Submodules
      • app.tasks.data_transformation.tasks module
      • Module contents
    • app.tasks.modeling package
      • Submodules
      • app.tasks.modeling.tasks module
      • Module contents
    • app.tasks.workflows package
      • Submodules
      • app.tasks.workflows.tasks module
      • Module contents
  • Module contents

Submodules

app.constants module

class EnvConfig(value)

Bases: Enum

API_BEARER_TOKEN = 'API_BEARER_TOKEN'

CELERY_BACKEND_CONNECTION = 'CELERY_BACKEND_CONNECTION'

CELERY_BROKER_CONNECTION = 'CELERY_BROKER_CONNECTION'

CELERY_DEFAULT_QUEUE = 'CELERY_DEFAULT_QUEUE'

PORT = 'VIRTUAL_PORT'

S3_ACCESS_KEY_ID = 'S3_ACCESS_KEY_ID'

S3_BUCKET_NAME = 'S3_BUCKET_NAME'

S3_ENDPOINT_URL = 'S3_ENDPOINT_URL'

S3_SECRET_ACCESS_KEY = 'S3_SECRET_ACCESS_KEY'

app.utils module

get_metadata(client, bucket: str, object_name: str) → dict

retrieve_metadata(data: pandas.DataFrame) → str

Module contents