comment out some tests for upkeep

this logic moved to get_pending_activation now.

Author: markstory

src/upkeep.rs

@@ -784,6 +784,7 @@ mod tests {
         .await;
     }
 
+    /*
     #[tokio::test]
     async fn test_processing_attempts_exceeded_discard() {
         let config = create_config();
@@ -832,6 +833,7 @@ mod tests {
             "complete tasks were removed"
         );
     }
+    */
 
     #[tokio::test]
     async fn test_remove_at_remove_failed_publish_to_kafka() {
@@ -921,6 +923,7 @@ mod tests {
         );
     }
 
+    /*
     #[tokio::test]
     async fn test_expired_discard() {
         let config = create_config();
@@ -949,7 +952,8 @@ mod tests {
         )
         .await;
 
-        assert_eq!(result_context.expired, 2); // 0/2 removed as expired
+        // expiration happens in get_pending_activation now
+        assert_eq!(result_context.expired, 0);
         assert_eq!(result_context.completed, 1); // 1 complete
         assert_eq!(
             store
@@ -985,6 +989,7 @@ mod tests {
             "fourth task should be kept"
         );
     }
+    */
 
     #[tokio::test]
     async fn test_delay_elapsed() {