`utils.rcclient.services.dataapp_service`

Module Contents

Classes

DataAppService

Attributes

`logger`
`plain_logger`
`PodStatus`

utils.rcclient.services.dataapp_service.logger

utils.rcclient.services.dataapp_service.plain_logger

utils.rcclient.services.dataapp_service.PodStatus

class utils.rcclient.services.dataapp_service.DataAppService

DATAAPPS_ENDPOINT = '/dataapps'

DATAAPP_ENDPOINT

DATAAPP_BYID_ENDPOINT

RECORD_DATAAPP_ACCESS_ENDPOINT

DATAAPP_LAUNCH_ENDPOINT

DATAAPP_STOP_ENDPOINT

DATAAPP_LOGS_ENDPOINT

DATAAPP_CONFIG_ENDPOINT

DATAAPPS_HEALTH_ENDPOINT

DATAAPPS_SCRIPT_HEALTH_ENDPOINT

DATAAPP_LAUNCH_DEV_APP_ENDPOINT

DATAAPPS_POD_STATUS_ENDPOINT

DATAAPPS_RESOURCE_USAGE_ENDPOINT

DATAAPPS_LOCAL_DIR

ENTRY_SCRIPT = Multiline-String

Show Value

"""
        from utils.rcclient.libs.streamlit_utils import auth_manager

        import app


        if __name__ == '__main__':
            if auth_manager.is_user_authorized():
                app.main()
    """

signed_url_client

file_upload_client

dataapp_client

classmethod get_local_dir()

__get_pod_status(dataapp_id: str)

__check_pod_status(dataapp_id)

check_resource_usage(dataapp)

__get_new_logs(dataapp_id, logs_received_till_last_run)

__status_changed_to_running(current_status, prev_status)

__handle_app_launch(dataapp, live_logs)

__make_script_health_check_call(dataapp: utils.rcclient.entities.dataapp.Dataapp)

launch(dataapp: utils.rcclient.entities.dataapp.Dataapp, live_logs: bool) → None

get_all() → List[utils.rcclient.entities.dataapp.Dataapp]

get(_id: str) → utils.rcclient.entities.dataapp.Dataapp

find_by_name(name: str) → utils.rcclient.entities.dataapp.Dataapp

fetch_config(dl_id: str)

save(dataapp: utils.rcclient.entities.dataapp.Dataapp) → utils.rcclient.entities.dataapp.Dataapp

__clean_metadata(dataapp)

__update_pages(slug, metadata)

__upload_dataapp_artifact(slug: str, file_path: str)

__update_logo(slug, metadata)

create(dataapp: utils.rcclient.entities.dataapp.Dataapp) → utils.rcclient.entities.dataapp.Dataapp

update(dataapp: utils.rcclient.entities.dataapp.Dataapp) → utils.rcclient.entities.dataapp.Dataapp

delete(_id: str) → None

stop(_id: str) → None

get_logs(_id: str, mode='offline') → None

__valid_code_loc(code_loc)

launch_dev_mode(dataapp, test_id, start_server, app_template)

__launch_streamlit_server(app_py_path: str)

stop_dev_mode()

record_dataapp_is_accessed(_id: str)

check_status(dataapp: utils.rcclient.entities.dataapp.Dataapp)

__copy_dataapp_artifacts(dataapp, base_path, prepared_metadata)

__prepare_for_testing(dataapp, app_template, test_id)