Module markov.dispatchers.model_dispatch

Functions

def add_experiment_to_model(model_id: str, experiment_id: str) ‑> bool
def add_metadata_to_model(model_id: str, metadata: Dict[str, str])
def create_model(name: str, project_id: str = '', description: str = '', model_class: ModelClass = ModelClass.CLASSIFICATION, metadata: Dict[str, str] = None) ‑> CreateModelResponse
def finish_model_upload(resource_identifier: str, upload_id: str, etags: List[str]) ‑> FinishModelUploadResponse
def get_all_model_registries()
def get_model_artifact_schema_and_samples(model_id: str)
def get_model_artifact_signed_url(model_id: str)
def get_model_by_id(model_id: str) ‑> GetModelResponse
def get_model_by_name(model_name: str, project_id: str) ‑> GetModelResponse
def get_model_files_signed_url(model_id: str)
def get_model_registry_by_id(registry_id: str)
def get_model_registry_by_name(registry_name: str)
def get_models_by_metadata(metadata: Dict[str, str], stage: Stage = None)
def set_model_artifact_upload_path(model_id: str, model_artifact_upload_path: str) ‑> FinishModelUploadResponse
def set_model_files_path(model_id: str, model_files_path: str)
def set_model_schema_and_samples(model_id: str, schema: List[MarkovModelArtifactColumnSchema], samples: List)
def start_concept_drift_monitor(model_id: str, y_true_train: List[str], y_pred_train: List[str]) ‑> StartModelConceptDriftMonitorResponse
def start_model_upload_with_presigned_urls(model_filepath: str, part_count: int, content_type: str) ‑> StartModelUploadWithPresignedUrlsResponse
def update_concept_drift_monitor(model_id: str, y_true: List[str], y_pred: List[str])
def update_model_class(model_id: str, model_class: ModelClass) ‑> bool
def update_model_stage_in_registry(model_id: str, to_stage: ModelRegistryStageStates)