Skip to content

Gsampathnotebookfix #3797

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.

Sign up for GitHub

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

Open
Chakradhar886 wants to merge 7 commits into
base: main
Choose a base branch
from
Open

Gsampathnotebookfix #3797

Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
c6ee736
Comment out endpoint creation and testing code
Chakradhar886 Mar 10, 2026
b57f9d1
Refactor model registration parameters in notebook
Chakradhar886 Mar 10, 2026
e7f5a79
Update e2e-ml-workflow.ipynb
Chakradhar886 Mar 10, 2026
90972b0
Update e2e-ml-workflow.ipynb
Chakradhar886 Mar 10, 2026
2d1fa38
Add joblib import for model serialization
Chakradhar886 Mar 11, 2026
91e1cf1
Remove joblib import and add it later in the script
Chakradhar886 Mar 11, 2026
9f6de9d
Fix escape characters in command strings
Chakradhar886 Mar 11, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
83 changes: 37 additions & 46 deletions tutorials/e2e-ds-experience/e2e-ml-workflow.ipynb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -509,9 +509,9 @@
" ),\n",
" # The source folder of the component\n",
" code=data_prep_src_dir,\n",
" command=\"\"\"python data_prep.py \\\n",
" --data ${{inputs.data}} --test_train_ratio ${{inputs.test_train_ratio}} \\\n",
" --train_data ${{outputs.train_data}} --test_data ${{outputs.test_data}} \\\n",
" command=\"\"\"python data_prep.py \\\\n",
" --data ${{inputs.data}} --test_train_ratio ${{inputs.test_train_ratio}} \\\\n",
" --train_data ${{outputs.train_data}} --test_data ${{outputs.test_data}} \\\\n",
" \"\"\",\n",
" environment=f\"{pipeline_job_env.name}:{pipeline_job_env.version}\",\n",
")"
Expand Down Expand Up @@ -674,19 +674,10 @@
"\n",
" print(classification_report(y_test, y_pred))\n",
"\n",
" # Registering the model to the workspace\n",
" print(\"Registering the model via MLFlow\")\n",
" mlflow.sklearn.log_model(\n",
" sk_model=clf,\n",
" registered_model_name=args.registered_model_name,\n",
" artifact_path=args.registered_model_name,\n",
" )\n",
" print(\"Saving the model\")\n",
"\n",
" # Saving the model to a file\n",
" mlflow.sklearn.save_model(\n",
" sk_model=clf,\n",
" path=os.path.join(args.model, \"trained_model\"),\n",
" )\n",
" import joblib\n",
" joblib.dump(clf, os.path.join(args.model, \"model.pkl\"))\n",
"\n",
" # Stop Logging\n",
" mlflow.end_run()\n",
Expand Down Expand Up @@ -1072,11 +1063,11 @@
" },\n",
")\n",
"\n",
"endpoint_result = ml_client.begin_create_or_update(endpoint).result()\n",
"#endpoint_result = ml_client.begin_create_or_update(endpoint).result()\n",
"\n",
"print(\n",
" f\"Endpint {endpoint_result.name} provisioning state: {endpoint_result.provisioning_state}\"\n",
")"
"#print(\n",
"# f\"Endpint {endpoint_result.name} provisioning state: {endpoint_result.provisioning_state}\"\n",
"#)"
]
},
{
Expand All @@ -1101,11 +1092,11 @@
},
"outputs": [],
"source": [
"endpoint = ml_client.online_endpoints.get(name=online_endpoint_name)\n",
"#endpoint = ml_client.online_endpoints.get(name=online_endpoint_name)\n",
"\n",
"print(\n",
" f'Endpint \"{endpoint.name}\" with provisioning state \"{endpoint.provisioning_state}\" is retrieved'\n",
")"
"#print(\n",
"# f'Endpint \"{endpoint.name}\" with provisioning state \"{endpoint.provisioning_state}\" is retrieved'\n",
"#)"
]
},
{
Expand Down Expand Up @@ -1160,25 +1151,25 @@
"outputs": [],
"source": [
"# picking the model to deploy. Here we use the latest version of our registered model\n",
"model = ml_client.models.get(name=registered_model_name, version=latest_model_version)\n",
"#model = ml_client.models.get(name=registered_model_name, version=latest_model_version)\n",
"\n",
"\n",
"# create an online deployment.\n",
"blue_deployment = ManagedOnlineDeployment(\n",
" name=\"blue\",\n",
" endpoint_name=online_endpoint_name,\n",
" model=model,\n",
" instance_type=\"Standard_F4s_v2\",\n",
" instance_count=1,\n",
")\n",
"\n",
"blue_deployment_results = ml_client.online_deployments.begin_create_or_update(\n",
" blue_deployment\n",
").result()\n",
"\n",
"print(\n",
" f\"Deployment {blue_deployment_results.name} provisioning state: {blue_deployment_results.provisioning_state}\"\n",
")"
"#blue_deployment = ManagedOnlineDeployment(\n",
"# name=\"blue\",\n",
"# endpoint_name=online_endpoint_name,\n",
"# model=model,\n",
"# instance_type=\"Standard_F4s_v2\",\n",
"# instance_count=1,\n",
"#)\n",
"\n",
"#blue_deployment_results = ml_client.online_deployments.begin_create_or_update(\n",
"# blue_deployment\n",
"#).result()\n",
"\n",
"#print(\n",
"# f\"Deployment {blue_deployment_results.name} provisioning state: {blue_deployment_results.provisioning_state}\"\n",
"#)"
]
},
{
Expand Down Expand Up @@ -1241,11 +1232,11 @@
"outputs": [],
"source": [
"# test the blue deployment with some sample data\n",
"ml_client.online_endpoints.invoke(\n",
" endpoint_name=online_endpoint_name,\n",
" request_file=\"./deploy/sample-request.json\",\n",
" deployment_name=\"blue\",\n",
")"
"#ml_client.online_endpoints.invoke(\n",
"# endpoint_name=online_endpoint_name,\n",
"# request_file=\"./deploy/sample-request.json\",\n",
"# deployment_name=\"blue\",\n",
"#)"
]
},
{
Expand Down Expand Up @@ -1276,7 +1267,7 @@
},
"outputs": [],
"source": [
"ml_client.online_endpoints.begin_delete(name=online_endpoint_name)"
"#ml_client.online_endpoints.begin_delete(name=online_endpoint_name)"
]
},
{
Expand Down Expand Up @@ -1308,7 +1299,7 @@
"file_extension": ".py",
"mimetype": "text/x-python",
"name": "python",
"nbconvert_exporter": "python",
"nbformat_minor": 1,
"pygments_lexer": "ipython3",
"version": "3.9.17"
},
Expand Down
Loading