code: def upgrade():
      """Apply Add index on state, dag_id for queued ``dagrun``"""
      with op.batch_alter_table("dag_run") as batch_op:
          batch_op.create_index(
              "idx_dag_run_queued_dags",
              ["state", "dag_id"],
              postgresql_where=text("state='queued'"),
              mssql_where=text("state='queued'"),
              sqlite_where=text("state='queued'"),
          )
  
imports: from __future__ import annotations
  from alembic import op
  from sqlalchemy import text
label_desc: Use image node_id 1 for calling a global function with example usage: upgrade() without return types