code: def verify_dataset_integrity(
      dataset_id: str, expected_num_columns: int
  ):
      print("starting verify_dataset_integrity")
      from clearml import Dataset, Logger
      from pathlib import Path
      import numpy as np
      import pandas as pd
  
      dataset = Dataset.get(dataset_id=dataset_id)
      local_folder = dataset.get_local_copy()
      df = pd.read_csv(Path(local_folder) / "dataset.csv")
      print("Verifying dataset")
      assert len(df.columns) == expected_num_columns
      print("PASSED")
      # log some stats on the age column
      Logger.current_logger().report_histogram(
          title="histogram",
          series="age",
          values=np.histogram(df["age"]),
      )
  
      print("done verify_dataset_integrity")
      return True
  
imports: from clearml import PipelineDecorator, Task
label_desc: Use image node_id 3 for calling a global function with example usage: verify_dataset_integrity(dataset_id, expected_num_columns) and returns: True