Diffusion dagster b13bf6047aab

Reintroduce daemon heartbeats
b13bf6047aab
Actions

Description

Reintroduce daemon heartbeats

Summary: This reverts commit 8f4d961aa6737bec01f8582e6d762de50e627065.

Test Plan:
Integration
()

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

Details

Provenance

johann

Authored on Nov 30 2020, 7:21 PM

Differential Revision

D5352: Reintroduce daemon heartbeats

Parents

R1:1733aa778666: enable reexecution when all required asset stores are non mem

Branches

Unknown

Tags

Unknown

Reverts

R1:8f4d961aa673: Revert "Daemon heartbeats backend"

Event Timeline

johann committed R1:b13bf6047aab: Reintroduce daemon heartbeats (authored by johann).Dec 1 2020, 8:36 PM

johann added a reverted change: R1:8f4d961aa673: Revert "Daemon heartbeats backend".

johann added an edge: D5352: Reintroduce daemon heartbeats.

Changes (15)

Path

Size

python_modules/

dagster/

core/

instance/

__init__.py

storage/

runs/

daemon/

dagster_tests/

core_tests/

storage_tests/

utils/

run_storage.py

daemon_tests/

integration_tests/

test_daemon.py

	test_queued.py
	test_queued_run_coordinator_integration.py

test_queued_run_coordinator_integration.py

utils.py

test_dagster_daemon.py

	python_modules/	dagster/

	dagster_tests/	daemon_tests/
	examples/	airflow_ingest/

__init__.py

	dagster_tests/	daemon_tests/	integration_tests/
		examples/	airflow_ingest/

__init__.py

R1:b13bf6047aab

View Options

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

View Options

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

View Options

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

View Options

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

View Options

python_modules/dagster/dagster/core/storage/runs/sql_run_storage.py

View Options

python_modules/dagster/dagster/daemon/controller.py

View Options

python_modules/dagster/dagster/daemon/types.py

View Options

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

View Options

python_modules/dagster/dagster_tests/daemon_tests/init.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/init.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/test_daemon.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/test_queued.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/test_queued_run_coordinator_integration.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/utils.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/test_dagster_daemon.py

Reintroduce daemon heartbeatsb13bf6047aabActions

Description

Details

Event Timeline

Changes (15)

R1:b13bf6047aab

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

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

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

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

python_modules/dagster/dagster/core/storage/runs/sql_run_storage.py

python_modules/dagster/dagster/daemon/controller.py

python_modules/dagster/dagster/daemon/types.py

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

python_modules/dagster/dagster_tests/daemon_tests/__init__.py

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/__init__.py

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/test_daemon.py

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/test_queued.py

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/test_queued_run_coordinator_integration.py

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/utils.py

python_modules/dagster/dagster_tests/daemon_tests/test_dagster_daemon.py

Reintroduce daemon heartbeats
b13bf6047aab
Actions

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

python_modules/dagster/dagster_tests/daemon_tests/init.py

python_modules/dagster/dagster_tests/daemon_tests/integration_tests/init.py