code: def my_test_function_1():
      return 1
  
file_path: spark/python/pyspark/sql/tests/streaming/test_streaming_foreach_batch.py
imports: import time
  from pyspark.sql.dataframe import DataFrame
  from pyspark.testing.sqlutils import ReusedSQLTestCase
label_desc: Use image node_id 1 for calling a global function with example usage: my_test_function_1() and returns: int