Skip to content

ci: disable builtin continual tasks #32506

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
May 22, 2025
Merged

ci: disable builtin continual tasks #32506

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 0 additions & 3 deletions doc/user/content/sql/system-catalog/mz_internal.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1299,8 +1299,6 @@ The `mz_webhook_sources` table contains a row for each webhook source in the sys
[`timestamp with time zone`]: /sql/types/timestamp

<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_activity_log_thinned -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_cluster_replica_metrics_history_ct -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_cluster_replica_status_history_ct -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_cluster_workload_classes -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_compute_error_counts_raw_unified -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_continual_tasks -->
Expand Down Expand Up @@ -1336,7 +1334,6 @@ The `mz_webhook_sources` table contains a row for each webhook source in the sys
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_storage_shards -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_storage_usage_by_shard -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_type_pg_metadata -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_wallclock_lag_history_ct -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_object_oid_alias -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_objects_id_namespace_types -->
<!-- RELATION_SPEC_UNDOCUMENTED mz_internal.mz_console_cluster_utilization_overview -->
Expand Down
3 changes: 0 additions & 3 deletions misc/python/materialize/mzcompose/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -99,9 +99,6 @@ def get_default_system_parameters(
"enable_compute_correction_v2": "true",
"enable_compute_logical_backpressure": "true",
"enable_connection_validation_syntax": "true",
"enable_continual_task_builtins": (
"true" if version > MzVersion.parse_mz("v0.127.0-dev") else "false"
),
"enable_continual_task_create": "true",
"enable_continual_task_retain": "true",
"enable_continual_task_transform": "true",
Expand Down
3 changes: 0 additions & 3 deletions test/sqllogictest/autogenerated/mz_internal.slt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -677,10 +677,8 @@ mz_cluster_deployment_lineage
mz_cluster_replica_history
mz_cluster_replica_metrics
mz_cluster_replica_metrics_history
mz_cluster_replica_metrics_history_ct
mz_cluster_replica_name_history
mz_cluster_replica_status_history
mz_cluster_replica_status_history_ct
mz_cluster_replica_statuses
mz_cluster_replica_utilization
mz_cluster_replica_utilization_history
Expand Down Expand Up @@ -790,7 +788,6 @@ mz_wallclock_global_lag_histogram_raw
mz_wallclock_global_lag_history
mz_wallclock_global_lag_recent_history
mz_wallclock_lag_history
mz_wallclock_lag_history_ct
mz_webhook_sources
pg_attrdef_all_databases
pg_attribute_all_databases
Expand Down
12 changes: 0 additions & 12 deletions test/sqllogictest/information_schema_tables.slt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -297,10 +297,6 @@ mz_cluster_replica_metrics_history
SOURCE
materialize
mz_internal
mz_cluster_replica_metrics_history_ct
CONTINUAL-TASK
materialize
mz_internal
mz_cluster_replica_name_history
VIEW
materialize
Expand All @@ -309,10 +305,6 @@ mz_cluster_replica_status_history
SOURCE
materialize
mz_internal
mz_cluster_replica_status_history_ct
CONTINUAL-TASK
materialize
mz_internal
mz_cluster_replica_statuses
BASE TABLE
materialize
Expand Down Expand Up @@ -749,10 +741,6 @@ mz_wallclock_lag_history
SOURCE
materialize
mz_internal
mz_wallclock_lag_history_ct
CONTINUAL-TASK
materialize
mz_internal
mz_webhook_sources
BASE TABLE
materialize
Expand Down
38 changes: 19 additions & 19 deletions test/sqllogictest/introspection/attribution_sources.slt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -119,17 +119,17 @@ SELECT mz_unsafe.mz_sleep(8)
query IT
SELECT id, global_id FROM mz_internal.mz_dataflow_global_ids ORDER BY id, global_id;
----
9 t50
9 t44


query TI
SELECT global_id, lir_id FROM mz_internal.mz_lir_mapping ORDER BY global_id, lir_id DESC;
----
t50 5
t50 4
t50 3
t50 2
t50 1
t44 5
t44 4
t44 3
t44 2
t44 1

## attribution queries

Expand All @@ -142,11 +142,11 @@ SELECT global_id, lir_id, parent_lir_id, REPEAT(' ', nesting * 2) || operator AS
GROUP BY global_id, lir_id, operator, parent_lir_id, nesting
ORDER BY global_id, lir_id DESC;
----
t50 5 NULL Join::Differential␠2␠»␠4
t50 4 5 ␠␠Arrange␠3
t50 3 4 ␠␠␠␠Get::Collection␠u4
t50 2 5 ␠␠Arrange␠1
t50 1 2 ␠␠␠␠Get::Collection␠u4
t44 5 NULL Join::Differential␠2␠»␠4
t44 4 5 ␠␠Arrange␠3
t44 3 4 ␠␠␠␠Get::Collection␠u4
t44 2 5 ␠␠Arrange␠1
t44 1 2 ␠␠␠␠Get::Collection␠u4

# omitting pg_size_pretty(sum(size)) as size
query TIIT
Expand All @@ -157,11 +157,11 @@ SELECT global_id, lir_id, parent_lir_id, REPEAT(' ', nesting * 2) || operator AS
GROUP BY global_id, lir_id, operator, parent_lir_id, nesting
ORDER BY global_id, lir_id DESC;
----
t50 5 NULL Join::Differential␠2␠»␠4
t50 4 5 ␠␠Arrange␠3
t50 3 4 ␠␠␠␠Get::Collection␠u4
t50 2 5 ␠␠Arrange␠1
t50 1 2 ␠␠␠␠Get::Collection␠u4
t44 5 NULL Join::Differential␠2␠»␠4
t44 4 5 ␠␠Arrange␠3
t44 3 4 ␠␠␠␠Get::Collection␠u4
t44 2 5 ␠␠Arrange␠1
t44 1 2 ␠␠␠␠Get::Collection␠u4

statement ok
DROP TABLE u CASCADE;
Expand Down Expand Up @@ -238,8 +238,8 @@ FROM mz_introspection.mz_mappable_objects LEFT JOIN mz_introspection.mz_lir_mapp
USING (global_id)
GROUP BY name, global_id;
----
materialize.public.w t81 5
materialize.public.v_idx_x u9 5
materialize.public.v_idx_x u10 2
materialize.public.v2_idx_x u7 2
materialize.public.v2_idx_x u8 2
materialize.public.v_idx_x u10 2
materialize.public.v_idx_x u9 5
materialize.public.w t75 5
2 changes: 1 addition & 1 deletion test/sqllogictest/mz_catalog_server_index_accounting.slt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ mz_message_batch_counts_received_raw_s2_primary_idx CREATE␠INDEX␠"mz_messag
mz_message_batch_counts_sent_raw_s2_primary_idx CREATE␠INDEX␠"mz_message_batch_counts_sent_raw_s2_primary_idx"␠IN␠CLUSTER␠[s2]␠ON␠"mz_introspection"."mz_message_batch_counts_sent_raw"␠("channel_id",␠"from_worker_id",␠"to_worker_id")
mz_message_counts_received_raw_s2_primary_idx CREATE␠INDEX␠"mz_message_counts_received_raw_s2_primary_idx"␠IN␠CLUSTER␠[s2]␠ON␠"mz_introspection"."mz_message_counts_received_raw"␠("channel_id",␠"from_worker_id",␠"to_worker_id")
mz_message_counts_sent_raw_s2_primary_idx CREATE␠INDEX␠"mz_message_counts_sent_raw_s2_primary_idx"␠IN␠CLUSTER␠[s2]␠ON␠"mz_introspection"."mz_message_counts_sent_raw"␠("channel_id",␠"from_worker_id",␠"to_worker_id")
mz_notices_ind CREATE␠INDEX␠"mz_notices_ind"␠IN␠CLUSTER␠[s2]␠ON␠[s794␠AS␠"mz_internal"."mz_notices"]␠("id")
mz_notices_ind CREATE␠INDEX␠"mz_notices_ind"␠IN␠CLUSTER␠[s2]␠ON␠[s791␠AS␠"mz_internal"."mz_notices"]␠("id")
mz_object_dependencies_ind CREATE␠INDEX␠"mz_object_dependencies_ind"␠IN␠CLUSTER␠[s2]␠ON␠[s459␠AS␠"mz_internal"."mz_object_dependencies"]␠("object_id")
mz_object_history_ind CREATE␠INDEX␠"mz_object_history_ind"␠IN␠CLUSTER␠[s2]␠ON␠[s524␠AS␠"mz_internal"."mz_object_history"]␠("id")
mz_object_lifetimes_ind CREATE␠INDEX␠"mz_object_lifetimes_ind"␠IN␠CLUSTER␠[s2]␠ON␠[s525␠AS␠"mz_internal"."mz_object_lifetimes"]␠("id")
Expand Down
3 changes: 0 additions & 3 deletions test/sqllogictest/oid.slt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1141,16 +1141,13 @@ SELECT oid, name FROM mz_objects WHERE id LIKE 's%' AND oid < 20000 ORDER BY oid
17025 mz_kafka_source_tables
17026 mz_continual_tasks
17027 mz_show_continual_tasks
17029 mz_cluster_replica_metrics_history_ct
17030 mz_objects_id_namespace_types
17031 mz_object_history
17032 mz_object_history_ind
17033 mz_cluster_replica_name_history
17034 mz_cluster_replica_name_history_ind
17035 mz_console_cluster_utilization_overview
17036 mz_console_cluster_utilization_overview_ind
17037 mz_cluster_replica_status_history_ct
17038 mz_wallclock_lag_history_ct
17039 mz_continual_tasks_ind
17040 mz_network_policies
17041 mz_network_policy_rules
Expand Down
1 change: 0 additions & 1 deletion test/testdrive/catalog.td
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -361,7 +361,6 @@ table
source
view
materialized-view
continual-task
sink
index
connection
Expand Down