code: def run_scheduler_job(with_db_reset=False) -> None:
      """
      Run the scheduler job, selectively resetting the db before creating a ScheduleJob instance
      """
      from airflow.jobs.scheduler_job_runner import SchedulerJobRunner
  
      if with_db_reset:
          reset_db()
      job_runner = SchedulerJobRunner(
          job=Job(), subdir=DAG_FOLDER, do_pickle=False, num_runs=3
      )
      run_job(job=job_runner.job, execute_callable=job_runner._execute)
  
file_path: airflow/dev/perf/sql_queries.py
imports: from __future__ import annotations
  import os
  import statistics
  import textwrap
  from time import monotonic, sleep
  from typing import NamedTuple
  import pandas
  from airflow.jobs.job import Job, run_job
label_desc: Use image node_id 2 for calling a global function with example usage: run_scheduler_job(with_db_reset) without return types