Differential D4743 Diff 24603 python_modules/dagster/dagster/core/storage/event_log/schema.py

Changeset View

Standalone View

	import sqlalchemy as db			import sqlalchemy as db

	SqlEventLogStorageMetadata = db.MetaData()			SqlEventLogStorageMetadata = db.MetaData()

	SqlEventLogStorageTable = db.Table(			SqlEventLogStorageTable = db.Table(
	"event_logs",			"event_logs",
	SqlEventLogStorageMetadata,			SqlEventLogStorageMetadata,
	db.Column("id", db.Integer, primary_key=True, autoincrement=True),			db.Column("id", db.Integer, primary_key=True, autoincrement=True),
	db.Column("run_id", db.String(255)),			db.Column("run_id", db.String(255)),
	db.Column("event", db.Text, nullable=False),			db.Column("event", db.Text, nullable=False),
	db.Column("dagster_event_type", db.Text),			db.Column("dagster_event_type", db.Text),
	db.Column("timestamp", db.types.TIMESTAMP),			db.Column("timestamp", db.types.TIMESTAMP(timezone=True)),
				dgibsonUnsubmitted Not Done Inline Actions do we need a migration for this? or are we fine with it only kicking in for new users? dgibson: do we need a migration for this? or are we fine with it only kicking in for new users?
	db.Column("step_key", db.String),			db.Column("step_key", db.String),
	db.Column("asset_key", db.String),			db.Column("asset_key", db.String),
	)			)

	SecondaryIndexMigrationTable = db.Table(			SecondaryIndexMigrationTable = db.Table(
	"secondary_indexes",			"secondary_indexes",
	SqlEventLogStorageMetadata,			SqlEventLogStorageMetadata,
	db.Column("id", db.Integer, primary_key=True, autoincrement=True),			db.Column("id", db.Integer, primary_key=True, autoincrement=True),
	Show All 16 Lines