40 lines
998 B
Python
40 lines
998 B
Python
"""Dagster jobs and schedules."""
|
|
|
|
from dagster import (
|
|
AssetSelection,
|
|
DefaultScheduleStatus,
|
|
RunConfig,
|
|
ScheduleDefinition,
|
|
define_asset_job,
|
|
)
|
|
|
|
from data_platform.assets.ingestion.funda.funda import (
|
|
FundaDetailsConfig,
|
|
FundaPriceHistoryConfig,
|
|
FundaSearchConfig,
|
|
)
|
|
|
|
funda_ingestion_job = define_asset_job(
|
|
name="funda_ingestion",
|
|
selection=AssetSelection.assets(
|
|
"funda_search_results",
|
|
"funda_listing_details",
|
|
"funda_price_history",
|
|
),
|
|
description="Full Funda ingestion pipeline.",
|
|
)
|
|
|
|
funda_ingestion_schedule = ScheduleDefinition(
|
|
name="funda_ingestion_schedule",
|
|
job=funda_ingestion_job,
|
|
cron_schedule="0 */4 * * *",
|
|
run_config=RunConfig(
|
|
ops={
|
|
"funda_search_results": FundaSearchConfig(),
|
|
"funda_listing_details": FundaDetailsConfig(),
|
|
"funda_price_history": FundaPriceHistoryConfig(),
|
|
}
|
|
),
|
|
default_status=DefaultScheduleStatus.RUNNING,
|
|
)
|