File tree Expand file tree Collapse file tree
misc/python/materialize/parallel_workload Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2216,20 +2216,10 @@ def run(self, exe: Executor) -> bool:
22162216 conn = None
22172217
22182218 try :
2219+ conn = self .create_system_connection (exe )
22192220 if cluster is not None :
2220- # Serialize with ReconfigureClusterAction: any managed-to-
2221- # managed ALTER CLUSTER folds onto an in-flight graceful
2222- # reconfiguration record and, lacking a WAIT clause, replaces
2223- # its deadline with the 24h default (SQL-568), which strands
2224- # the reconfiguration that action is polling on.
2225- # TODO: Reenable running without the lock when SQL-568 is fixed
2226- with cluster .lock :
2227- if cluster not in exe .db .clusters :
2228- return False
2229- conn = self .create_system_connection (exe )
2230- self .set_cluster_compression (conn , cluster )
2221+ self .set_cluster_compression (conn , cluster )
22312222 else :
2232- conn = self .create_system_connection (exe )
22332223 self .flip_flag (conn , flag_name , flag_value )
22342224 exe .db .flags [flag_name ] = flag_value
22352225 return True
You can’t perform that action at this time.
0 commit comments