This commit is contained in:
2026-07-23 07:48:34 +01:00
commit 50c1e2cff8
53 changed files with 3286 additions and 0 deletions
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,7 @@
2026-07-23 07:41:35 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93784 - LOGS_CAPTURED - Capturing logs for process (pid: 93784).
2026-07-23 07:41:35 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93784 - orders - STEP_START - Started execution of step "orders".
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93784 - orders - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - orders - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/orders using PickledObjectFilesystemIOManager...
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93784 - orders - ASSET_MATERIALIZATION - Materialized value orders.
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93784 - orders - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93784 - orders - STEP_SUCCESS - Finished execution of step "orders" in 956ms.
@@ -0,0 +1,7 @@
2026-07-23 07:41:35 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93783 - LOGS_CAPTURED - Capturing logs for process (pid: 93783).
2026-07-23 07:41:35 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93783 - customers - STEP_START - Started execution of step "customers".
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93783 - customers - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - customers - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/customers using PickledObjectFilesystemIOManager...
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93783 - customers - ASSET_MATERIALIZATION - Materialized value customers.
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93783 - customers - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:41:36 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93783 - customers - STEP_SUCCESS - Finished execution of step "customers" in 683ms.
@@ -0,0 +1,7 @@
2026-07-23 07:41:35 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93785 - LOGS_CAPTURED - Capturing logs for process (pid: 93785).
2026-07-23 07:41:35 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93785 - payments - STEP_START - Started execution of step "payments".
2026-07-23 07:41:37 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93785 - payments - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:41:37 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - payments - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/payments using PickledObjectFilesystemIOManager...
2026-07-23 07:41:37 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93785 - payments - ASSET_MATERIALIZATION - Materialized value payments.
2026-07-23 07:41:37 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93785 - payments - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:41:37 +0100 - dagster - DEBUG - __ASSET_JOB - 32f542a5-d346-4f9f-9770-8c8036d72111 - 93785 - payments - STEP_SUCCESS - Finished execution of step "payments" in 1.8s.
@@ -0,0 +1,7 @@
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64416 - LOGS_CAPTURED - Capturing logs for process (pid: 64416).
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64416 - payments - STEP_START - Started execution of step "payments".
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64416 - payments - STEP_OUTPUT - Yielded output "result" of type "String". (Type check passed).
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - payments - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/payments using PickledObjectFilesystemIOManager...
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64416 - payments - ASSET_MATERIALIZATION - Materialized value payments.
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64416 - payments - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64416 - payments - STEP_SUCCESS - Finished execution of step "payments" in 23ms.
@@ -0,0 +1,7 @@
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64414 - LOGS_CAPTURED - Capturing logs for process (pid: 64414).
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64414 - customers - STEP_START - Started execution of step "customers".
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64414 - customers - STEP_OUTPUT - Yielded output "result" of type "String". (Type check passed).
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - customers - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/customers using PickledObjectFilesystemIOManager...
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64414 - customers - ASSET_MATERIALIZATION - Materialized value customers.
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64414 - customers - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64414 - customers - STEP_SUCCESS - Finished execution of step "customers" in 20ms.
@@ -0,0 +1,7 @@
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64415 - LOGS_CAPTURED - Capturing logs for process (pid: 64415).
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64415 - orders - STEP_START - Started execution of step "orders".
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64415 - orders - STEP_OUTPUT - Yielded output "result" of type "String". (Type check passed).
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - orders - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/orders using PickledObjectFilesystemIOManager...
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64415 - orders - ASSET_MATERIALIZATION - Materialized value orders.
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64415 - orders - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:31:54 +0100 - dagster - DEBUG - __ASSET_JOB - 578f973d-2672-4656-9a65-90fa6a6996b6 - 64415 - orders - STEP_SUCCESS - Finished execution of step "orders" in 22ms.
@@ -0,0 +1,7 @@
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108002 - LOGS_CAPTURED - Capturing logs for process (pid: 108002).
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108002 - payments - STEP_START - Started execution of step "payments".
2026-07-23 07:46:32 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108002 - payments - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:46:32 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - payments - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/payments using PickledObjectFilesystemIOManager...
2026-07-23 07:46:32 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108002 - payments - ASSET_MATERIALIZATION - Materialized value payments.
2026-07-23 07:46:32 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108002 - payments - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:46:32 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108002 - payments - STEP_SUCCESS - Finished execution of step "payments" in 838ms.
@@ -0,0 +1,7 @@
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108000 - LOGS_CAPTURED - Capturing logs for process (pid: 108000).
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108000 - customers - STEP_START - Started execution of step "customers".
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108000 - customers - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - customers - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/customers using PickledObjectFilesystemIOManager...
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108000 - customers - ASSET_MATERIALIZATION - Materialized value customers.
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108000 - customers - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108000 - customers - STEP_SUCCESS - Finished execution of step "customers" in 106ms.
@@ -0,0 +1,7 @@
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108001 - LOGS_CAPTURED - Capturing logs for process (pid: 108001).
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108001 - orders - STEP_START - Started execution of step "orders".
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108001 - orders - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - orders - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/orders using PickledObjectFilesystemIOManager...
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108001 - orders - ASSET_MATERIALIZATION - Materialized value orders.
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108001 - orders - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:46:31 +0100 - dagster - DEBUG - __ASSET_JOB - 6ba93bf3-34c3-4a98-9926-b1003610e991 - 108001 - orders - STEP_SUCCESS - Finished execution of step "orders" in 359ms.
@@ -0,0 +1,7 @@
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - 109730 - LOGS_CAPTURED - Capturing logs for process (pid: 109730).
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - 109730 - orders_aggregation - STEP_START - Started execution of step "orders_aggregation".
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - 109730 - orders_aggregation - STEP_OUTPUT - Yielded output "result" of type "Any". (Type check passed).
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - orders_aggregation - Writing file at: /mnt/bulk/source/dagster-intro/.tmp_dagster_home_e8m4zq2a/storage/orders_aggregation using PickledObjectFilesystemIOManager...
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - 109730 - orders_aggregation - ASSET_MATERIALIZATION - Materialized value orders_aggregation.
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - 109730 - orders_aggregation - HANDLED_OUTPUT - Handled output "result" using IO manager "io_manager"
2026-07-23 07:46:56 +0100 - dagster - DEBUG - __ASSET_JOB - bd2759e0-f8cd-4707-8fde-a00bbae926f6 - 109730 - orders_aggregation - STEP_SUCCESS - Finished execution of step "orders_aggregation" in 49ms.
@@ -0,0 +1 @@
N.
@@ -0,0 +1 @@
N.
@@ -0,0 +1 @@
N.
@@ -0,0 +1 @@
N.