Merge pull request 'fix(queue-daemon): source pm-agent.env for GITEA_TOKEN instead of default.env' (#162) from fix/issue-160-gitea-token-from-pm-agent into main

skills/kugetsu/scripts/kugetsu

@@ -310,31 +310,12 @@ get_pending_tasks() {
         return
     fi
     
-    python3 -c "
+    find "$QUEUE_ITEMS_DIR" -name "*.json" -type f 2>/dev/null | while read -r file; do
-import json
+        local state=$(python3 -c "import json; print(json.load(open('$file')).get('state', ''))" 2>/dev/null || echo "")
-import os
+        if [ "$state" = "pending" ]; then
-import sys
+            cat "$file"
-
+        fi
-queue_dir = os.environ.get('QUEUE_ITEMS_DIR', '')
+    done | head -"$limit"
-limit = int(sys.argv[1]) if len(sys.argv) > 1 else 10
-
-items = []
-if os.path.isdir(queue_dir):
-    for filename in os.listdir(queue_dir):
-        if filename.endswith('.json'):
-            filepath = os.path.join(queue_dir, filename)
-            try:
-                with open(filepath) as f:
-                    data = json.load(f)
-                    if data.get('state') == 'pending':
-                        items.append(data)
-                        if len(items) >= limit:
-                            break
-            except:
-                pass
-
-print(json.dumps(items))
-" "$limit"
 }
 
 get_queue_stats() {