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

Groq autotracing #14006

Merged
merged 11 commits into from
Dec 26, 2024
Merged

Groq autotracing #14006

merged 11 commits into from
Dec 26, 2024

Conversation

anumita0203
Copy link
Contributor

@anumita0203 anumita0203 commented Dec 7, 2024

🛠 DevTools 🛠

Open in GitHub Codespaces

Install mlflow from this PR

# Use `%sh` to run this command on Databricks
OPTIONS=$(if pip freeze | grep -q 'mlflow @ git+https://github.com/mlflow/mlflow.git'; then echo '--force-reinstall --no-deps'; fi)
pip install $OPTIONS git+https://github.com/mlflow/mlflow.git@refs/pull/14006/merge

Checkout with GitHub CLI

gh pr checkout 14006

Related Issues/PRs

Resolve #13911

What changes are proposed in this pull request?

Add Autolog tracing integration for Groq.

Screenshot from 2024-12-07 19-26-20

How is this PR tested?

  • Existing unit/integration tests
  • New unit/integration tests
  • Manual tests

Does this PR require documentation update?

  • No. You can skip the rest of this section.
  • Yes. I've updated:
    • Examples
    • API references
    • Instructions

Release Notes

Is this a user-facing change?

  • No. You can skip the rest of this section.
  • Yes. Give a description of this change to be included in the release notes for MLflow users.

Add Autolog tracing integration for Groq.

What component(s), interfaces, languages, and integrations does this PR affect?

Components

  • area/artifacts: Artifact stores and artifact logging
  • area/build: Build and test infrastructure for MLflow
  • area/deployments: MLflow Deployments client APIs, server, and third-party Deployments integrations
  • area/docs: MLflow documentation pages
  • area/examples: Example code
  • area/model-registry: Model Registry service, APIs, and the fluent client calls for Model Registry
  • area/models: MLmodel format, model serialization/deserialization, flavors
  • area/recipes: Recipes, Recipe APIs, Recipe configs, Recipe Templates
  • area/projects: MLproject format, project running backends
  • area/scoring: MLflow Model server, model deployment tools, Spark UDFs
  • area/server-infra: MLflow Tracking server backend
  • area/tracking: Tracking Service, tracking client APIs, autologging

Interface

  • area/uiux: Front-end, user experience, plotting, JavaScript, JavaScript dev server
  • area/docker: Docker use across MLflow's components, such as MLflow Projects and MLflow Models
  • area/sqlalchemy: Use of SQLAlchemy in the Tracking Service or Model Registry
  • area/windows: Windows support

Language

  • language/r: R APIs and clients
  • language/java: Java APIs and clients
  • language/new: Proposals for new client languages

Integrations

  • integrations/azure: Azure and Azure ML integrations
  • integrations/sagemaker: SageMaker integrations
  • integrations/databricks: Databricks integrations

How should the PR be classified in the release notes? Choose one:

  • rn/none - No description will be included. The PR will be mentioned only by the PR number in the "Small Bugfixes and Documentation Updates" section
  • rn/breaking-change - The PR will be mentioned in the "Breaking Changes" section
  • rn/feature - A new user-facing feature worth mentioning in the release notes
  • rn/bug-fix - A user-facing bug fix worth mentioning in the release notes
  • rn/documentation - A user-facing documentation change worth mentioning in the release notes

Should this PR be included in the next patch release?

Yes should be selected for bug fixes, documentation updates, and other small changes. No should be selected for new features and larger changes. If you're unsure about the release classification of this PR, leave this unchecked to let the maintainers decide.

What is a minor/patch release?
  • Minor release: a release that increments the second part of the version number (e.g., 1.2.0 -> 1.3.0).
    Bug fixes, doc updates and new features usually go into minor releases.
  • Patch release: a release that increments the third part of the version number (e.g., 1.2.0 -> 1.2.1).
    Bug fixes and doc updates usually go into patch releases.
  • Yes (this PR will be cherry-picked and included in the next patch release)
  • No (this PR will be included in the next minor release)

Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Copy link

github-actions bot commented Dec 7, 2024

@anumita0203 Thank you for the contribution! Could you fix the following issue(s)?

⚠ DCO check

The DCO check failed. Please sign off your commit(s) by following the instructions here. See https://github.com/mlflow/mlflow/blob/master/CONTRIBUTING.md#sign-your-work for more details.

@github-actions github-actions bot added the rn/feature Mention under Features in Changelogs. label Dec 7, 2024
Copy link

github-actions bot commented Dec 7, 2024

Documentation preview for bb3263a will be available when this CircleCI job
completes successfully.

More info

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Aside from the documentation, could you update a few more files to make CI pass? Reference: https://github.com/mlflow/mlflow/pull/13851/files

  • Add tests/groq to the conftest.py
  • Add groq to the ml-package-versions.yml file. The file defines supported versions and some installation commands for the CI. You can follow the format of anthropic. For maximum version, please set the latest version. Minimum version doesn't have to be very accurate.

Comment on lines 10 to 12
from mlflow.groq._groq_autolog import (
patched_call,
)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
from mlflow.groq._groq_autolog import (
patched_call,
)
from mlflow.groq._groq_autolog import patched_call

Comment on lines 42 to 43
if Version(_get_groq_package_version()) < Version("0.13.0"):
raise MlflowException("Groq autologging is only supported for groq >= 0.13.0")
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Once you added the minimum version in ml-package-versions.yml, you can remove this validation🙂

ChatCompletions: SpanType.CHAT_MODEL,
Embeddings: SpanType.EMBEDDING,
}
return span_type_mapping.get(task, SpanType.UNKNOWN)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
return span_type_mapping.get(task, SpanType.UNKNOWN)
return span_type_mapping.get(task, SpanType.LLM)

Let's use LLM type for translation / translations

Comment on lines 26 to 30
config = AutoLoggingConfig.init(flavor_name=mlflow.groq.FLAVOR_NAME)
active_run = mlflow.active_run()

# Active run should always take precedence over the run_id stored in the model
run_id = active_run.info.run_id if active_run else getattr(self, "_mlflow_run_id", None)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Only trace logging is required for now, so we don't need to manage Run logic. You can refer to anthropic implementation to simplify the logic here. (Sorry I should have refer it instead of OpenAI in the guidance).

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Great test coverage!

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks 😊

Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Copy link
Collaborator

@B-Step62 B-Step62 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The change overall looks great! I think we are very close to the goal🙂

A few more formal changes to make things work and test pass:

  • Add groq = LazyLoader("mlflow.groq", globals(), "mlflow.groq") in mlflow/init.py to allow lazy import.
  • Add "groq": "mlflow.groq" to this dictionary so that it is integrated to the global mlflow.autolog() API.

Once these are addressed, we should be good to merge and release this in next month. Thank you for putting effort on this, @anumita0203 !!

return DUMMY_CHAT_COMPLETION_RESPONSE


def test_chat_completion_autolog():
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

According to the error message here, it seems we need to set some dummy API key in the environment variable for testing, even if we patch the client.

Comment on lines 14 to 15
def _get_groq_package_version():
return importlib.metadata.version("groq")
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: we can remove this function

anumita0203 and others added 4 commits December 25, 2024 13:06
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Yuki Watanabe <31463517+B-Step62@users.noreply.github.com>
Signed-off-by: B-Step62 <yuki.watanabe@databricks.com>
Copy link
Collaborator

@B-Step62 B-Step62 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!

@B-Step62 B-Step62 added this pull request to the merge queue Dec 26, 2024
Merged via the queue into mlflow:master with commit 7f056ad Dec 26, 2024
42 checks passed
karthikkurella pushed a commit to karthikkurella/mlflow that referenced this pull request Jan 30, 2025
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Yuki Watanabe <31463517+B-Step62@users.noreply.github.com>
Signed-off-by: B-Step62 <yuki.watanabe@databricks.com>
Co-authored-by: Yuki Watanabe <31463517+B-Step62@users.noreply.github.com>
Co-authored-by: B-Step62 <yuki.watanabe@databricks.com>
Signed-off-by: k99kurella <karthikkurella4@gmail.com>
karthikkurella pushed a commit to karthikkurella/mlflow that referenced this pull request Jan 30, 2025
Signed-off-by: Anumita Dasgupta <anumita0302@gmail.com>
Signed-off-by: Yuki Watanabe <31463517+B-Step62@users.noreply.github.com>
Signed-off-by: B-Step62 <yuki.watanabe@databricks.com>
Co-authored-by: Yuki Watanabe <31463517+B-Step62@users.noreply.github.com>
Co-authored-by: B-Step62 <yuki.watanabe@databricks.com>
Signed-off-by: k99kurella <karthikkurella4@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
rn/feature Mention under Features in Changelogs.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[FR] MLflow Tracing for Groq
2 participants