[hotfix] validate env before getting gateway client (#2973)

confluentinc · Dec 16, 2024 · eba43e8 · eba43e8
1 parent abe2c13
commit eba43e8
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/internal/flink/command_connection_list.go b/internal/flink/command_connection_list.go
@@ -34,11 +34,6 @@ func (c *command) newConnectionListCommand() *cobra.Command {
 }
 
 func (c *command) connectionList(cmd *cobra.Command, _ []string) error {
-	client, err := c.GetFlinkGatewayClient(false)
-	if err != nil {
-		return err
-	}
-
 	environmentId, err := c.Context.EnvironmentId()
 	if err != nil {
 		return err
@@ -59,6 +54,11 @@ func (c *command) connectionList(cmd *cobra.Command, _ []string) error {
 		}
 	}
 
+	client, err := c.GetFlinkGatewayClient(false)
+	if err != nil {
+		return err
+	}
+
 	connections, err := client.ListConnections(environmentId, c.Context.GetCurrentOrganization(), strings.ToUpper(connectionType))
 	if err != nil {
 		return err