We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d40ba14 commit cd35fc1Copy full SHA for cd35fc1
v03_pipeline/lib/tasks/dataproc/create_dataproc_cluster.py
@@ -170,9 +170,7 @@ def complete(self) -> bool:
170
google.cloud.dataproc_v1.types.clusters.ClusterStatus.State.ERROR,
171
google.cloud.dataproc_v1.types.clusters.ClusterStatus.State.ERROR_DUE_TO_UPDATE,
172
}:
173
- msg = (
174
- f'Cluster {cluster.cluster_name} entered {cluster.status.state.name} state'
175
- )
+ msg = f'Cluster {cluster.cluster_name} entered {cluster.status.state.name} state'
176
logger.error(msg)
177
# This will return False when the cluster is "CREATING"
178
return (
0 commit comments