code: def create_jobs(self):
      datetime_format = "%Y-%m-%d %H:%M:%S"
      start_time = (datetime.now() - timedelta(seconds=10)).strftime(
          datetime_format
      )
      end_time = (datetime.now() + timedelta(seconds=60)).strftime(
          datetime_format
      )
  
      create_csv_query = """CREATE TABLE IF NOT EXISTS MyCSV (
                                      id INTEGER UNIQUE,
                                      frame_id INTEGER,
                                      video_id INTEGER
                                  );
                              """
      job_1_query = f"""CREATE JOB IF NOT EXISTS {self.job_name_1} AS {{
                                  SELECT * FROM MyCSV;
                              }}
                              START '{start_time}'
                              END '{end_time}'
                              EVERY 4 seconds;
                          """
      job_2_query = f"""CREATE JOB IF NOT EXISTS {self.job_name_2} AS {{
                              SHOW FUNCTIONS;
                          }}
                          START '{start_time}'
                          END '{end_time}'
                          EVERY 2 seconds;
                      """
  
      execute_query_fetch_all(self.evadb, create_csv_query)
      execute_query_fetch_all(self.evadb, job_1_query)
      execute_query_fetch_all(self.evadb, job_2_query)
  
file_path: evadb/test/integration_tests/long/test_job_scheduler_execution.py
imports: import time
  import unittest
  from datetime import datetime, timedelta
  from test.util import get_evadb_for_testing, shutdown_ray
  from mock import MagicMock
  from evadb.interfaces.relational.db import EvaDBConnection
  from evadb.server.command_handler import execute_query_fetch_all
label_desc: Use image node_id 5 for calling the JobSchedulerIntegrationTests obj's underlying member method code with example usage: obj.create_jobs() without return types