Marco
02/23/2021, 9:21 PMsandy
02/23/2021, 9:31 PMfrom unittest.mock import MagicMock
from dagster import DagsterInstance, SensorExecutionContext
def test_first_events():
context = SensorExecutionContext(
instance=MagicMock(spec=DagsterInstance),
last_run_key=None,
last_completion_time=None,
)
requests = story_recommender_sensor.get_execution_data(context)
assert len(requests) == 1
assert requests[0].run_key == "1|2"
Marco
02/23/2021, 9:33 PMsandy
02/23/2021, 9:50 PMMarco
02/23/2021, 9:50 PMsandy
02/23/2021, 9:51 PMstory_recommender_sensor
is a SensorDefinition
. the decorator returns a SensorDefinition
, not a functionMarco
02/23/2021, 10:18 PM