Vignesh M
03/06/2023, 7:39 AMget_event_records
on a run-sharded event log storage with a cursor that
is not run-aware. Add a RunShardedEventsCursor to your query filter
or switch your instance configuration to use a non-run-sharded event log storage
(e.g. PostgresEventLogStorage, ConsolidatedSqliteEventLogStorage)chris
03/06/2023, 9:20 PMget_event_records
?Vignesh M
03/07/2023, 9:59 AMevent_records = list(
context.instance.get_event_records(
EventRecordsFilter(
event_type=DagsterEventType.PIPELINE_SUCCESS,
after_cursor=cursor,
),
ascending=True,
)
)
chris
05/26/2023, 4:11 PM