Paths

Table of Contentst

event log / instance api for event_records
825836167c3e
Actions

Description

event log / instance api for event_records

Summary:
Rather than have the include_cursor flag determine the return value of events_for_asset_key,
introduce a event_records_for_asset_key instance method and document it

Test Plan: bk

Reviewers: yuhan, sandyryza, alangenfeld

Reviewed By: yuhan

Differential Revision: https://dagster.phacility.com/D8610

Details

Provenance

• prha

Authored on Jun 29 2021, 11:01 PM

Reviewer

yuhan

Differential Revision

D8610: event log / instance api for event_records

Parents

R1:ac931b1663b9: Configure task_definition and container_name

Branches

Unknown

Tags

Unknown

Event Timeline

• prha committed R1:825836167c3e: event log / instance api for event_records (authored by • prha).Jul 2 2021, 9:26 PM

• prha added an edge: D8610: event log / instance api for event_records.

Changes (18)

Path

Size

docs/

content/

concepts/

partitions-schedules-sensors/

sensors.mdx

sphinx/

sections/

api/

apidocs/

internals.rst

examples/

docs_snippets/

concepts/

partitions_schedules_sensors/

sensors/

sensors.py

hacker_news/

sensors/

hn_tables_updated_sensor.py

hacker_news_tests/

test_sensors/

test_hn_tables_updated_sensor.py

python_modules/

dagster-graphql/

dagster_graphql/

implementation/

fetch_assets.py

schema/

inputs.py

dagster-test/

dagster_test/

toys/

sensors.py

dagster/

__init__.py

core/

definitions/

pipeline_sensor.py

instance/

__init__.py

storage/

event_log/

sqlite/

consolidated_sqlite_event_log.py

sqlite_event_log.py

dagster_tests/

core_tests/

storage_tests/

utils/

event_log_storage.py

R1:825836167c3e

View Options

docs/content/concepts/partitions-schedules-sensors/sensors.mdx

View Options

docs/sphinx/sections/api/apidocs/internals.rst

View Options

examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/sensors.py

View Options

examples/hacker_news/hacker_news/sensors/hn_tables_updated_sensor.py

View Options

examples/hacker_news/hacker_news_tests/test_sensors/test_hn_tables_updated_sensor.py

View Options

python_modules/dagster-graphql/dagster_graphql/implementation/fetch_assets.py

View Options

python_modules/dagster-graphql/dagster_graphql/schema/inputs.py

View Options

python_modules/dagster-test/dagster_test/toys/sensors.py

View Options

python_modules/dagster/dagster/init.py

View Options

python_modules/dagster/dagster/core/definitions/pipeline_sensor.py

View Options

python_modules/dagster/dagster/core/instance/init.py

View Options

python_modules/dagster/dagster/core/storage/event_log/init.py

View Options

python_modules/dagster/dagster/core/storage/event_log/base.py

View Options

python_modules/dagster/dagster/core/storage/event_log/in_memory.py

View Options

python_modules/dagster/dagster/core/storage/event_log/sql_event_log.py

View Options

python_modules/dagster/dagster/core/storage/event_log/sqlite/consolidated_sqlite_event_log.py

View Options

python_modules/dagster/dagster/core/storage/event_log/sqlite/sqlite_event_log.py

View Options

python_modules/dagster/dagster_tests/core_tests/storage_tests/utils/event_log_storage.py

event log / instance api for event_records825836167c3eActions

Description

Details

Event Timeline

Changes (18)

R1:825836167c3e

docs/content/concepts/partitions-schedules-sensors/sensors.mdx

docs/sphinx/sections/api/apidocs/internals.rst

examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/sensors.py

examples/hacker_news/hacker_news/sensors/hn_tables_updated_sensor.py

examples/hacker_news/hacker_news_tests/test_sensors/test_hn_tables_updated_sensor.py

python_modules/dagster-graphql/dagster_graphql/implementation/fetch_assets.py

python_modules/dagster-graphql/dagster_graphql/schema/inputs.py

python_modules/dagster-test/dagster_test/toys/sensors.py

python_modules/dagster/dagster/__init__.py

python_modules/dagster/dagster/core/definitions/pipeline_sensor.py

python_modules/dagster/dagster/core/instance/__init__.py

python_modules/dagster/dagster/core/storage/event_log/__init__.py

python_modules/dagster/dagster/core/storage/event_log/base.py

python_modules/dagster/dagster/core/storage/event_log/in_memory.py

python_modules/dagster/dagster/core/storage/event_log/sql_event_log.py

python_modules/dagster/dagster/core/storage/event_log/sqlite/consolidated_sqlite_event_log.py

python_modules/dagster/dagster/core/storage/event_log/sqlite/sqlite_event_log.py

python_modules/dagster/dagster_tests/core_tests/storage_tests/utils/event_log_storage.py

event log / instance api for event_records
825836167c3e
Actions

python_modules/dagster/dagster/init.py

python_modules/dagster/dagster/core/instance/init.py

python_modules/dagster/dagster/core/storage/event_log/init.py