code: def load_adult_dataset(**context):
      df_train, df_test = adult.load_data(data_format="Dataframe")
  
      try:
          os.mkdir(data_path)
      except OSError:
          print("Creation of the directory {} failed".format(dir_path))
  
      with open(os.path.join(data_path, "adult_train.csv"), "w") as f:
          df_train.to_csv(f, index=False)
          context["ti"].xcom_push(
              key="train_path",
              value=os.path.join(data_path, "adult_train.csv"),
          )
      with open(os.path.join(data_path, "adult_test.csv"), "w") as f:
          df_test.to_csv(f, index=False)
          context["ti"].xcom_push(
              key="test_path",
              value=os.path.join(data_path, "adult_test.csv"),
          )
  
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 1 for calling a global function with example usage: load_adult_dataset() without return types