Differential D5228 Diff 26378 python_modules/dagster/dagster/core/storage/schedules/schema.py

Changeset View

Standalone View

python_modules/dagster/dagster/core/storage/schedules/schema.py

	Show First 20 Lines • Show All 44 Lines • ▼ Show 20 Lines

	JobTickTable = db.Table(			JobTickTable = db.Table(
	"job_ticks",			"job_ticks",
	ScheduleStorageSqlMetadata,			ScheduleStorageSqlMetadata,
	db.Column("id", db.Integer, primary_key=True, autoincrement=True),			db.Column("id", db.Integer, primary_key=True, autoincrement=True),
	db.Column("job_origin_id", db.String(255), index=True),			db.Column("job_origin_id", db.String(255), index=True),
	db.Column("status", db.String(63)),			db.Column("status", db.String(63)),
	db.Column("type", db.String(63)),			db.Column("type", db.String(63)),
	db.Column("execution_key", db.String),			db.Column("run_key", db.String),
	db.Column("timestamp", db.types.TIMESTAMP),			db.Column("timestamp", db.types.TIMESTAMP),
	db.Column("tick_body", db.String),			db.Column("tick_body", db.String),
	db.Column("create_timestamp", db.DateTime, server_default=db.text("CURRENT_TIMESTAMP")),			db.Column("create_timestamp", db.DateTime, server_default=db.text("CURRENT_TIMESTAMP")),
	db.Column("update_timestamp", db.DateTime, server_default=db.text("CURRENT_TIMESTAMP")),			db.Column("update_timestamp", db.DateTime, server_default=db.text("CURRENT_TIMESTAMP")),
	)			)

	db.Index("idx_job_tick_execution_key", JobTickTable.c.job_origin_id, JobTickTable.c.execution_key)			db.Index("idx_job_tick_run_key", JobTickTable.c.job_origin_id, JobTickTable.c.run_key)
	db.Index("idx_job_tick_status", JobTickTable.c.job_origin_id, JobTickTable.c.status)			db.Index("idx_job_tick_status", JobTickTable.c.job_origin_id, JobTickTable.c.status)
	db.Index("idx_job_tick_timestamp", JobTickTable.c.job_origin_id, JobTickTable.c.timestamp)			db.Index("idx_job_tick_timestamp", JobTickTable.c.job_origin_id, JobTickTable.c.timestamp)