Struct MlflowTrackingClient

Source
pub struct MlflowTrackingClient { /* private fields */ }
Expand description

Provides access to a MLflow tracking server via REST API.

Support Mlflow API version 2.0.

Implementations§

Source§

impl MlflowTrackingClient

Source

pub fn new(base_url: impl AsRef<str>) -> Self

Source

pub fn basic_auth( self, user_name: impl AsRef<str>, password: impl AsRef<str>, ) -> Self

Sets user name and password for basic authentication of the tracking server.

Source

pub fn set_experiment( self, name: impl AsRef<str>, ) -> Result<Self, GetExperimentIdError>

Sets an experiment with the given name to this struct.

Source

pub fn get_experiment(&self, name: impl AsRef<str>) -> Option<Experiment>

Gets [Experiment] by name from the tracking server.

If the experiment with given name does not exist in the trackingserver, it will be created.

TODO: Better error handling

Source

pub fn create_recorder<E, R>( &self, run_name: impl AsRef<str>, ) -> Result<MlflowTrackingRecorder<E, R>>
where E: Env, R: ReplayBufferBase,

Create MlflowTrackingRecorder corresponding to a run.

If name is empty (""), a run name is generated by the tracking server.

If a Run with name exists in the tracking server, the run is used to create the recorder. If two or more runs with name exists, this method panics.

You need to set an experiment using MlflowTrackingClient::set_experiment() before calling this method.

This method uses MLFLOW_DEFAULT_ARTIFACT_ROOT environment variable as the directory where artifacts, like model parameters, will be saved. It is recommended to set this environment variable mlruns directory to which the tracking server persists experiment and run data.

Source

pub fn get_runs_by_name(&self, name: impl AsRef<str>) -> Result<Vec<Run>>

Get runs by names.

This method queries the tracking server and returns Runs.

Trait Implementations§

Source§

impl Debug for MlflowTrackingClient

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,