code: def test_autologging_multiple_reads_same_run(
      spark_session, format_to_file_path
  ):
      mlflow.spark.autolog()
      with mlflow.start_run():
          for data_format, file_path in format_to_file_path.items():
              run_id = mlflow.active_run().info.run_id
              df = spark_session.read.format(data_format).load(
                  file_path
              )
              df.collect()
              time.sleep(1)
          run = mlflow.get_run(run_id)
          assert _SPARK_TABLE_INFO_TAG_NAME in run.data.tags
          table_info_tag = run.data.tags[_SPARK_TABLE_INFO_TAG_NAME]
          assert table_info_tag == "\n".join(
              [
                  _get_expected_table_info_row(path, data_format)
                  for data_format, path in format_to_file_path.items()
              ]
          )
  
file_path: mlflow/tests/spark/autologging/datasource/test_spark_datasource_autologging.py
imports: import time
  from unittest import mock
  from pyspark.sql import Row
  from pyspark.sql.types import IntegerType, StructField, StructType
  import mlflow
  import mlflow.spark
  from mlflow._spark_autologging import _SPARK_TABLE_INFO_TAG_NAME
  from mlflow.utils.validation import MAX_TAG_VAL_LENGTH
  from tests.spark.autologging.utils import _assert_spark_data_logged
  from tests.tracking.integration_test_utils import _init_server
label_desc: Use image node_id 5 for calling a global function with example usage: test_autologging_multiple_reads_same_run(spark_session, format_to_file_path) without return types