code: def dataset_integrity_step(**context):
      from deepchecks.tabular.suites import data_integrity
      from deepchecks.tabular.datasets.classification.adult import (
          _CAT_FEATURES,
          _target,
      )
      from deepchecks.tabular import Dataset
  
      adult_train = pd.read_csv(
          context.get("ti").xcom_pull(key="train_path")
      )
      adult_test = pd.read_csv(
          context.get("ti").xcom_pull(key="test_path")
      )
  
      ds_train = Dataset(
          adult_train, label=_target, cat_features=_CAT_FEATURES
      )
      ds_test = Dataset(
          adult_test, label=_target, cat_features=_CAT_FEATURES
      )
  
      train_results = data_integrity().run(ds_train)
      test_results = data_integrity().run(ds_test)
  
      try:
          os.mkdir("suite_results")
      except OSError:
          print("Creation of the directory {} failed".format(dir_path))
  
      run_time = datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
      train_results.save_as_html(
          os.path.join(dir_path, f"train_integrity_{run_time}.html")
      )
      test_results.save_as_html(
          os.path.join(dir_path, f"test_integrity_{run_time}.html")
      )
  
file_path: deepchecks/examples/integrations/airflow/deepchecks_airflow_tutorial.py
imports: from datetime import datetime, timedelta
  import os
  from airflow import DAG
  from airflow.operators.python import PythonOperator
  import joblib
  import pandas
  from deepchecks.tabular.datasets.classification import adult
label_desc: Use image node_id 3 for calling a global function with example usage: dataset_integrity_step() without return types