code: def test_sub_process(df: pl.DataFrame, job_id):
      df_filtered = df.filter(pl.col("a") > 0)
      print(f"Filtered (job_id: {job_id})", df_filtered, sep="\n")
  
imports: import multiprocessing
  import polars
label_desc: Use image node_id 1 for calling a global function with example usage: test_sub_process(df, job_id) without return types