fix: handle rate limits (429) and processing-completed state in task polling

crates/redis-cloud/src/client.rs

@@ -255,6 +255,7 @@ impl CloudClient {
                 403 => Err(RestError::Forbidden { message: text }),
                 404 => Err(RestError::NotFound { message: text }),
                 412 => Err(RestError::PreconditionFailed),
+                429 => Err(RestError::RateLimited { message: text }),
                 500 => Err(RestError::InternalServerError { message: text }),
                 503 => Err(RestError::ServiceUnavailable { message: text }),
                 _ => Err(RestError::ApiError {
@@ -305,6 +306,7 @@ impl CloudClient {
                 403 => Err(RestError::Forbidden { message: text }),
                 404 => Err(RestError::NotFound { message: text }),
                 412 => Err(RestError::PreconditionFailed),
+                429 => Err(RestError::RateLimited { message: text }),
                 500 => Err(RestError::InternalServerError { message: text }),
                 503 => Err(RestError::ServiceUnavailable { message: text }),
                 _ => Err(RestError::ApiError {
@@ -384,6 +386,7 @@ impl CloudClient {
                 403 => Err(RestError::Forbidden { message: text }),
                 404 => Err(RestError::NotFound { message: text }),
                 412 => Err(RestError::PreconditionFailed),
+                429 => Err(RestError::RateLimited { message: text }),
                 500 => Err(RestError::InternalServerError { message: text }),
                 503 => Err(RestError::ServiceUnavailable { message: text }),
                 _ => Err(RestError::ApiError {
@@ -451,6 +454,7 @@ impl CloudClient {
                 403 => Err(RestError::Forbidden { message: text }),
                 404 => Err(RestError::NotFound { message: text }),
                 412 => Err(RestError::PreconditionFailed),
+                429 => Err(RestError::RateLimited { message: text }),
                 500 => Err(RestError::InternalServerError { message: text }),
                 503 => Err(RestError::ServiceUnavailable { message: text }),
                 _ => Err(RestError::ApiError {

crates/redis-cloud/src/lib.rs

@@ -363,6 +363,9 @@ pub enum CloudError {
     #[error("Precondition Failed (412): Feature flag for this flow is off")]
     PreconditionFailed,
 
+    #[error("Rate Limited (429): {message}")]
+    RateLimited { message: String },
+
     #[error("Internal Server Error (500): {message}")]
     InternalServerError { message: String },
 
@@ -379,6 +382,24 @@ pub enum CloudError {
     JsonError(String),
 }
 
+impl CloudError {
+    /// Returns true if this error is retryable.
+    ///
+    /// Retryable errors include:
+    /// - Rate limited (429)
+    /// - Service unavailable (503)
+    /// - Connection/request errors (may be transient network issues)
+    pub fn is_retryable(&self) -> bool {
+        matches!(
+            self,
+            CloudError::RateLimited { .. }
+                | CloudError::ServiceUnavailable { .. }
+                | CloudError::Request(_)
+                | CloudError::ConnectionError(_)
+        )
+    }
+}
+
 impl From<reqwest::Error> for CloudError {
     fn from(err: reqwest::Error) -> Self {
         CloudError::Request(err.to_string())

crates/redis-cloud/src/lib_tests.rs

@@ -103,6 +103,58 @@ mod tests {
         assert_eq!(err.to_string(), "API error (400): Bad request");
     }
 
+    #[test]
+    fn test_cloud_error_is_retryable() {
+        // Retryable errors
+        assert!(
+            CloudError::RateLimited {
+                message: "Too many requests".to_string()
+            }
+            .is_retryable()
+        );
+        assert!(
+            CloudError::ServiceUnavailable {
+                message: "Service down".to_string()
+            }
+            .is_retryable()
+        );
+        assert!(CloudError::Request("Connection reset".to_string()).is_retryable());
+        assert!(CloudError::ConnectionError("DNS failed".to_string()).is_retryable());
+
+        // Non-retryable errors
+        assert!(
+            !CloudError::BadRequest {
+                message: "Invalid input".to_string()
+            }
+            .is_retryable()
+        );
+        assert!(
+            !CloudError::AuthenticationFailed {
+                message: "Bad creds".to_string()
+            }
+            .is_retryable()
+        );
+        assert!(
+            !CloudError::Forbidden {
+                message: "No access".to_string()
+            }
+            .is_retryable()
+        );
+        assert!(
+            !CloudError::NotFound {
+                message: "Not found".to_string()
+            }
+            .is_retryable()
+        );
+        assert!(
+            !CloudError::ApiError {
+                code: 400,
+                message: "Error".to_string()
+            }
+            .is_retryable()
+        );
+    }
+
     #[tokio::test]
     async fn test_url_normalization() {
         // Test various combinations of base URLs and paths to ensure no double slashes

crates/redisctl/Cargo.toml

@@ -52,7 +52,7 @@ thiserror = { workspace = true }
 serde_yaml = { workspace = true }
 comfy-table = { workspace = true }
 jmespath = { workspace = true }
-jmespath_extensions = { version = "0.7", features = ["full"] }
+jmespath_extensions = { version = "0.8", features = ["full"] }
 config = { workspace = true }
 
 # Keyring for Files.com API key storage (separate from profile credentials)

crates/redisctl/src/cli/cloud.rs

@@ -1660,7 +1660,7 @@ NOTE: The maximum date range is 40 days. Cost reports are generated asynchronous
     redisctl cloud cost-report download cost-report-12345-abcdef
 
     # Download cost report to a file
-    redisctl cloud cost-report download cost-report-12345-abcdef --output report.csv
+    redisctl cloud cost-report download cost-report-12345-abcdef --file report.csv
 
 NOTE: The costReportId is returned in the task response after the generation completes.
       Check task status with 'redisctl cloud task get <task-id>' to get the costReportId.
@@ -1670,8 +1670,8 @@ NOTE: The costReportId is returned in the task response after the generation com
         cost_report_id: String,
 
         /// Output file path (defaults to stdout if not specified)
-        #[arg(long, short)]
-        output: Option<String>,
+        #[arg(long = "file", short = 'f')]
+        file: Option<String>,
     },
 }