Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Proposal to buffer service requests #41

Open
ablaom opened this issue Mar 6, 2024 · 1 comment
Open

Proposal to buffer service requests #41

ablaom opened this issue Mar 6, 2024 · 1 comment

Comments

@ablaom
Copy link
Member

ablaom commented Mar 6, 2024

The context of this proposal is this synchronisation issue.

The main problem with logging in parallelized operations is simply this: requests are
posted directly to an MLflow service without full information about the state the service
at the time the request is ultimately acted on. I propose we resolve this as follows:

  • Instead of a client posting requests directly to an MLflow service, they are posted
    (put!) to a first-in-first-out queue (Julia Channel). Requesting calls will return
    immediately, unless the queue is full. In this way, the performance of the parallel
    workload is not impacted.

  • A single Julia Task dispatches requests (take!s) from the end of the queue. Whenever
    a request has the possibility of altering the service state (e.g., creating an
    experiment), then the dispatcher waits for confirmation that the state change is
    complete before dispatching the next request.

I imagine that we can insert the queue (buffer) without breaking the user-facing
interface of MLFlowClient.jl.

I have implemented a POC for this proposal and shared it with two maintainers, and can share with anyone else interested.

@pebeto
Copy link
Member

pebeto commented May 20, 2024

This requirement is a very specific task. Not everyone is using multithreading/multiprocessing to perform this kind of operations.
MLFlowClient.jl is mirroring the capabilities the original package is performing. So, in my point of view, we must not implement a buffering solution here. This is something the user will take care of.
In the MLJ.jl context, our library MLJFlow.jl contains two POC workaround using Locks and Channels. It can be seen here JuliaAI/MLJFlow.jl#36.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants