topic Re: Dynamic Jobs community Edition in Data Engineering

Dynamic Jobs community Edition

Ritesh-Dhumne — Mon, 06 Oct 2025 07:08:52 GMT

Hello I tried this,

Notebook 1 :

dbutils.jobs.taskValues.set(key = "my_key", value = "hi From Notebook1")

Notebook2:

X = dbutils.jobs.taskValues.get(taskKey="01", key="my_key", debugValue = "Fail")

print(X)

Here I get "Fail" as output, its not fetching my_key

Re: Dynamic Jobs community Edition

saurabh18cs — Mon, 06 Oct 2025 07:35:58 GMT

Hi @Ritesh-Dhumne f you run both notebooks manually or outside a Databricks job with multiple tasks, taskValues will not work as expected. you should define your job with multiple tasks in Databricks Workflows.

Re: Dynamic Jobs community Edition

szymon_dybczak — Mon, 06 Oct 2025 08:09:57 GMT

Hi @Ritesh-Dhumne ,

Folllow my steps. I created 2 notebooks:

- first one called Notebook1 with followign content

- second one called Notebook2 with following content that will read value defined in Notebook1

Here's my definiton of workflow that is using those 2 notebooks:

Pay attention to my taskKey in get method is named the same as the task in a workflow (Notebook1):

When I ran workflow it works as expected:

)

Re: Dynamic Jobs community Edition

Ritesh-Dhumne — Mon, 06 Oct 2025 09:32:30 GMT

Could u Provide me the code and flow.

Re: Dynamic Jobs community Edition

Ritesh-Dhumne — Mon, 06 Oct 2025 10:09:17 GMT

hi @szymon_dybczak , Could u help me in a scenario like I'm trying to build a pipeline where notebook1 captures the file name and format of the file in the catalog . Notebook2 will take the filename and format from notebook1 and perform Basic transformations.

Re: Dynamic Jobs community Edition

szymon_dybczak — Mon, 06 Oct 2025 10:59:14 GMT

Hi @Ritesh-Dhumne ,

Sure, but could you describe what you need help with? What's the problem? 🙂

Re: Dynamic Jobs community Edition

Ritesh-Dhumne — Tue, 07 Oct 2025 05:02:56 GMT

I wanted to extract all files in the volume I have uploaded , in notebook 1 and then in notebook 2 perform basic transformation , also I want to store the null , dirty records seperately and a clean dataframe seperately for all the files .In Community Edition

Re: Dynamic Jobs community Edition

szymon_dybczak — Tue, 07 Oct 2025 08:36:02 GMT

Hi @Ritesh-Dhumne ,

I'm assuming that you mistakenly named Free Edition as Community since you're using volumes.

I’m not sure if I’ve understood your approach correctly, but at first glance it seems incorrect - you can’t pass a DataFrame between tasks. What you can do is load all the files from the volume into a bronze table in Notebook1. You can use the special _metadata column to add information about the file_path from which each particular row originates. Here’s an example of how to use it:

Then, in Notebook2, you can apply your transformations based on this bronze table. You can count nulls, handle dirty data, and benefit from the fact that you can relate all these issues to a particular file, since this information is added to the bronze table through the _metadata special column.

From what I see you're in a learning process so I won't introduce the concept of autoloader which is pretty handy for ingestion of files 🙂