Adonis
12/17/2020, 3:24 PMsandy
12/17/2020, 3:48 PMAdonis
12/17/2020, 3:52 PMsandy
12/17/2020, 4:23 PMAdonis
12/17/2020, 4:43 PMdaniel
12/17/2020, 4:46 PMAdonis
12/17/2020, 4:49 PMdaniel
12/17/2020, 4:55 PMAdonis
12/17/2020, 5:02 PMdaniel
12/17/2020, 5:07 PMAdonis
12/17/2020, 5:09 PM0.9.21
...$pip freeze | grep dagster
dagster==0.9.21
dagster-cron==0.9.21
dagster-graphql==0.9.21
dagster-pandas==0.9.21
dagster-postgres==0.9.21
daniel
12/17/2020, 5:16 PMAdonis
12/17/2020, 5:21 PM$ dagster pipeline backfill -p total_groene_mient_etl_gm -w ./dagster/workspace.yaml --location scp_data_app.repos.groene_mient --partitions 2020-04-01
$ PYTHONPATH=. dagster pipeline backfill -p total_groene_mient_etl_gm -w ./dagster/workspace.yaml --location scp_data_app.repos.groene_mient --partitions 2020-04-01
Pipeline: total_groene_mient_etl_gm
Partition set: monthly_total_groene_mient_etl_gm
Partitions:
2020-04-01
Do you want to proceed with the backfill (1 partitions)? [y/N]: y
Launching runs...
Launched backfill job `lpugyymr`
$ dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - ENGINE_EVENT - Starting initialization of resources [asset_store, measurement_metadata_repo, measurement_publisher, measurement_repo].
2020-12-17 18:19:25 - dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - ENGINE_EVENT - Finished initialization of resources [asset_store, measurement_metadata_repo, measurement_publisher, measurement_repo].
2020-12-17 18:19:25 - dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - PIPELINE_START - Started execution of pipeline "total_groene_mient_etl_gm".
2020-12-17 18:19:27 - dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - ENGINE_EVENT - Executing steps using multiprocess executor: parent process (pid: 13471)
2020-12-17 18:19:27 - dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - total.extract_total_house_energy_demand.compute - ENGINE_EVENT - Launching subprocess for total.extract_total_house_energy_demand.compute
2020-12-17 18:19:27 - dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - total.extract_total_house_energy_supply.compute - ENGINE_EVENT - Launching subprocess for total.extract_total_house_energy_supply.compute
2020-12-17 18:19:27 - dagster - DEBUG - total_groene_mient_etl_gm - 5b832854-a8c9-4631-922d-c4399a16f276 - 13471 - total.extract_total_house_heating_consumption.compute - ENGINE_EVENT - Launching subprocess for total.extract_total_house_heating_consumption.compute
daniel
12/17/2020, 5:22 PMAdonis
12/18/2020, 10:05 AM{
"id": "33",
"type": "start",
"payload": {
"variables": {
"backfillParams": {
"selector": {
"partitionSetName": "monthly_total_schoonschip_etl_sc",
"repositorySelector": {
"repositoryName": "schoonschip",
"repositoryLocationName": "scp_data_app.repos.schoonschip"
}
},
"partitionNames": [
"2020-11-01"
],
"reexecutionSteps": [
"total.compute",
"extract_total_house_battery_consumption.compute",
"transform_total_house_battery_consumption.compute",
"load_total_house_battery_consumption.compute",
"extract_total_house_battery_production.compute",
"transform_total_house_battery_production.compute",
"load_total_house_battery_production.compute",
"extract_total_house_battery_soc.compute",
"transform_total_house_battery_soc.compute",
"load_total_house_battery_soc.compute",
"extract_total_house_heating_consumption.compute",
"transform_total_house_heating_consumption.compute",
"load_total_house_heating_consumption.compute",
"extract_total_house_pv_production.compute",
"transform_total_house_pv_production.compute",
"load_total_house_pv_production.compute"
],
"fromFailure": false,
"tags": []
}
},
"extensions": {},
"operationName": "LaunchPartitionBackfill",
"query": "mutation LaunchPartitionBackfill($backfillParams: PartitionBackfillParams!) {\n launchPartitionBackfill(backfillParams: $backfillParams) {\n __typename\n ... on PartitionBackfillSuccess {\n backfillId\n __typename\n }\n ... on PartitionSetNotFoundError {\n message\n __typename\n }\n ... on PythonError {\n message\n stack\n __typename\n }\n }\n}\n"
}
}
daniel
12/18/2020, 1:17 PMAdonis
12/18/2020, 2:56 PMdaniel
12/18/2020, 3:00 PM