operator: ensure redis key updated back to 'interrupted', ensure exec time updated on pause

Author: ikreymer

backend/btrixcloud/operator/crawls.py

@@ -267,8 +267,10 @@ async def sync_crawls(self, data: MCSyncData):
                     params,
                 )
 
+            force_update = crawl.paused_at and status.stopReason != "paused"
+
             await self.increment_pod_exec_time(
-                pods, crawl, status, EXEC_TIME_UPDATE_SECS
+                pods, crawl, status, EXEC_TIME_UPDATE_SECS if not force_update else 0
             )
 
         else:
@@ -877,15 +879,12 @@ async def sync_crawl_state(
             if status.anyCrawlPodNewExit:
                 await self.log_crashes(crawl.id, status.podStatus, redis)
 
-                if crawl.paused_at and redis:
-                    for name in pods.keys():
-                        pod_status = status.podStatus[name]
-                        if (
-                            pod_status.isNewExit
-                            and pod_status.exitTime
-                            and pod_status.reason == "done"
-                        ):
-                            await redis.hset(f"{crawl.id}:status", name, "interrupted")
+            if crawl.paused_at and redis:
+                for name in pods.keys():
+                    pod_status = status.podStatus[name]
+                    if pod_status.exitTime and pod_status.reason == "done":
+                        await redis.hset(f"{crawl.id}:status", name, "interrupted")
+                        pod_status.reason = "paused"
 
             # remove stopping key (used for pause) unless actually stopping if:
             # 1. no more crawler pods running (to allow easily to resume)