Anonymous
Not applicable
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
05-13-2023 09:53 AM
@Grégoire PORTIER :
You can use the dbutils module to retrieve the job ID and run ID from within your Python wheel application. Here's an example of how you can do this:
from pyspark.sql import SparkSession
import requests
import json
import os
# Get the current SparkSession
spark = SparkSession.builder.getOrCreate()
# Get the Databricks job ID and run ID from the environment variables
job_id = os.environ.get("DATABRICKS_JOB_ID")
run_id = os.environ.get("DATABRICKS_RUN_ID")
# Print the job ID and run ID for logging/monitoring purposes
print(f"Databricks Job ID: {job_id}")
print(f"Databricks Run ID: {run_id}")You can then add this code to your Python wheel task to extract the job ID and run ID and use them for logging/monitoring purposes.
Note that the environment variables DATABRICKS_JOB_ID and DATABRICKS_RUN_ID are automatically set by Databricks when you run a job, so you don't need to pass them as parameters.