PostgreSQL (dagster-postgres)

dagster_postgres.PostgresEventLogStorage = <class 'dagster_postgres.event_log.event_log.PostgresEventLogStorage'>[source]

Config Schema:
postgres_url (dagster.StringSource, optional)

postgres_db (strict dict, optional)
Config Schema:
username (dagster.StringSource)

password (dagster.StringSource)

hostname (dagster.StringSource)

db_name (dagster.StringSource)

port (dagster.IntSource, optional)

Default Value: 5432

params (permissive dict, optional)
Default Value:
{}
should_autocreate_tables (Bool, optional)

Default Value: True

Postgres-backed event log storage.

Users should not directly instantiate this class; it is instantiated by internal machinery when dagit and dagster-graphql load, based on the values in the dagster.yaml file in $DAGSTER_HOME. Configuration of this class should be done by setting values in that file.

To use Postgres for event log storage, you can add a block such as the following to your dagster.yaml:

dagster.yaml
event_log_storage:
  module: dagster_postgres.event_log
  class: PostgresEventLogStorage
  config:
    postgres_db:
      username: { username }
      password: { password }
      hostname: { hostname }
      db_name: { db_name }
      port: { port }

Note that the fields in this config are StringSource and IntSource and can be configured from environment variables.

dagster_postgres.PostgresRunStorage = <class 'dagster_postgres.run_storage.run_storage.PostgresRunStorage'>[source]

Config Schema:
postgres_url (dagster.StringSource, optional)

postgres_db (strict dict, optional)
Config Schema:
username (dagster.StringSource)

password (dagster.StringSource)

hostname (dagster.StringSource)

db_name (dagster.StringSource)

port (dagster.IntSource, optional)

Default Value: 5432

params (permissive dict, optional)
Default Value:
{}
should_autocreate_tables (Bool, optional)

Default Value: True

Postgres-backed run storage.

Users should not directly instantiate this class; it is instantiated by internal machinery when dagit and dagster-graphql load, based on the values in the dagster.yaml file in $DAGSTER_HOME. Configuration of this class should be done by setting values in that file.

To use Postgres for run storage, you can add a block such as the following to your dagster.yaml:

dagster.yaml
run_storage:
  module: dagster_postgres.run_storage
  class: PostgresRunStorage
  config:
    postgres_db:
      username: { username }
      password: { password }
      hostname: { hostname }
      db_name: { database }
      port: { port }

Note that the fields in this config are StringSource and IntSource and can be configured from environment variables.

dagster_postgres.PostgresScheduleStorage = <class 'dagster_postgres.schedule_storage.schedule_storage.PostgresScheduleStorage'>[source]

Config Schema:
postgres_url (dagster.StringSource, optional)

postgres_db (strict dict, optional)
Config Schema:
username (dagster.StringSource)

password (dagster.StringSource)

hostname (dagster.StringSource)

db_name (dagster.StringSource)

port (dagster.IntSource, optional)

Default Value: 5432

params (permissive dict, optional)
Default Value:
{}
should_autocreate_tables (Bool, optional)

Default Value: True

Postgres-backed run storage.

Users should not directly instantiate this class; it is instantiated by internal machinery when dagit and dagster-graphql load, based on the values in the dagster.yaml file in $DAGSTER_HOME. Configuration of this class should be done by setting values in that file.

To use Postgres for schedule storage, you can add a block such as the following to your dagster.yaml:

dagster.yaml
schedule_storage:
  module: dagster_postgres.schedule_storage
  class: PostgresScheduleStorage
  config:
    postgres_db:
      username: { username }
      password: { password }
      hostname: { hostname }
      db_name: { db_name }
      port: { port }

Note that the fields in this config are StringSource and IntSource and can be configured from environment variables.