diff --git a/orchestrator.log b/orchestrator.log new file mode 100644 index 0000000..158369d --- /dev/null +++ b/orchestrator.log @@ -0,0 +1,221 @@ +Swarm Orchestrator started polling in /usr/local/google/home/jerxie/Projects/PersonalProject/cortex-hub/swarm_framework/comms/requests... +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438857.9174128, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438859.9298477, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438861.9462748, last_cmd_time: 0 +Processing req_test_hang (Type: prompt) for agent_1... +Completed req_test_hang +Debug [check_hanging]: Agent: agent_1, is_busy: True, now: 1775438868.9885714, last_cmd_time: 1775438861.946762 +Debug [check_hanging]: Agent: agent_1, current_output len: 836, prev_output len: 0 +Debug [check_hanging]: Agent: agent_1, output changed. +Debug [check_hanging]: Agent: agent_1, is_busy: True, now: 1775438871.0241537, last_cmd_time: 1775438861.946762 +Debug [check_hanging]: Agent: agent_1, current_output len: 836, prev_output len: 836 +Debug [check_hanging]: Agent: agent_1, silence_duration: 2.0355823040008545 +Debug [check_hanging]: Agent: agent_1, is_busy: True, now: 1775438873.064759, last_cmd_time: 1775438861.946762 +Debug [check_hanging]: Agent: agent_1, current_output len: 836, prev_output len: 836 +Debug [check_hanging]: Agent: agent_1, silence_duration: 4.076187610626221 +Debug [check_hanging]: Agent: agent_1, is_busy: True, now: 1775438875.1031532, last_cmd_time: 1775438861.946762 +Debug [check_hanging]: Agent: agent_1, current_output len: 836, prev_output len: 836 +Debug [check_hanging]: Agent: agent_1, silence_duration: 6.114581823348999 +Detected hanging agent: agent_1 +Notifying master about hanging agent agent_1... +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438877.149152, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438879.1643543, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438881.1911387, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438883.2046928, last_cmd_time: 0 +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Error listing agents: Command 'tmux list-windows -t jetski_swarm -F '#{window_name}'' returned non-zero exit status 1. +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438919.4431126, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438919.4431126, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438921.467022, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438921.467022, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438923.4873056, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438923.4873056, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438925.5223348, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438925.5223348, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438927.5560167, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438927.5560167, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438929.6355486, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438929.6355486, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438931.6612916, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438931.6612916, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438933.6730871, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438933.6730871, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438935.6853085, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438935.6853085, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438937.6966631, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438937.6966631, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438939.711031, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438939.711031, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438941.722107, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438941.722107, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438943.7342777, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438943.7342777, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438945.7467868, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438945.7467868, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438947.7653568, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438947.7653568, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438949.7795424, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438949.7795424, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438951.7922297, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438951.7922297, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438953.8052378, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438953.8052378, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438955.8180773, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438955.8180773, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438957.8298798, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438957.8298798, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438959.8423252, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438959.8423252, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438961.8553128, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438961.8553128, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438963.8676112, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438963.8676112, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438965.886971, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438965.886971, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438967.8996255, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438967.8996255, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438969.9114609, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438969.9114609, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438971.9227114, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438971.9227114, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438973.9344158, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438973.9344158, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438975.9459956, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438975.9459956, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438977.9571826, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438977.9571826, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438979.9737785, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438979.9737785, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438981.9846153, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438981.9846153, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438983.9975424, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438983.9975424, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438986.0119588, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438986.0119588, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438988.0236251, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438988.0236251, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438990.0365767, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438990.0365767, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438992.0494316, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438992.0494316, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438994.062068, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438994.062068, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438996.0738723, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438996.0738723, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775438998.086627, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775438998.086627, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439000.102641, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439000.102641, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439002.114711, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439002.114711, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439004.1267426, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439004.1267426, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439006.1389058, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439006.1389058, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439008.1524372, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439008.1524372, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439010.16589, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439010.16589, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439012.1794248, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439012.1794248, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439014.1916945, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439014.1916945, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439016.2038925, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439016.2038925, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439018.2164805, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439018.2164805, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439020.2291129, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439020.2291129, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439022.2413707, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439022.2413707, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439024.2530804, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439024.2530804, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439026.2650428, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439026.2650428, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439028.2773209, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439028.2773209, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439030.2897003, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439030.2897003, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439032.301625, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439032.301625, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439034.3266532, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439034.3266532, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439036.3388612, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439036.3388612, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439038.3558545, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439038.3558545, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439040.3683183, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439040.3683183, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439042.4091723, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439042.4091723, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439044.4227462, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439044.4227462, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439046.4345148, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439046.4345148, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439048.4474058, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439048.4474058, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439050.460654, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439050.460654, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439052.472683, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439052.472683, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439054.5007536, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439054.5007536, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439056.5206838, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439056.5206838, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439058.5427341, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439058.5427341, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439060.560675, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439060.560675, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439062.5886893, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439062.5886893, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439064.6017528, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439064.6017528, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439066.613212, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_2, is_busy: False, now: 1775439066.613212, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439068.6268754, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439068.6268754, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439070.6426954, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439070.6426954, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439072.663636, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439072.663636, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439074.6770258, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439074.6770258, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439076.6893165, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439076.6893165, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439078.7011387, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439078.7011387, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439080.7169087, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439080.7169087, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439082.730314, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439082.730314, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439084.7430565, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439084.7430565, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439086.7579484, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439086.7579484, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439088.7986362, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439088.7986362, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439090.813328, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439090.813328, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439092.826106, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439092.826106, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439094.8381567, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439094.8381567, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439096.8542817, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439096.8542817, last_cmd_time: 0 +Debug [check_hanging]: Agent: orchestrator, is_busy: False, now: 1775439098.8675618, last_cmd_time: 0 +Debug [check_hanging]: Agent: agent_1, is_busy: False, now: 1775439098.8675618, last_cmd_time: 0 diff --git a/swarm_framework/comms/responses/res_commit_push_20260406_2.json b/swarm_framework/comms/responses/res_commit_push_20260406_2.json new file mode 100644 index 0000000..63e7e15 --- /dev/null +++ b/swarm_framework/comms/responses/res_commit_push_20260406_2.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_commit_push_20260406_2", + "status": "success", + "output": " \u25b8 Thought for 1s, 105 tokens\n Wait, `swarm_framework/orchestrator.py` is modified again?\n \u2584\n \u25cf Bash(git diff swarm_framework/orchestrator.py) (ctrl+o to expand) \u2580\n \u28bf Ah, someone (likely the user or another process) h......\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_agent4.json b/swarm_framework/comms/responses/res_git_push_agent4.json new file mode 100644 index 0000000..dc419c3 --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_agent4.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_agent4", + "status": "success", + "output": " \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n > Please perform a git commit and push\n in the repository at . First, run .\n Then commit with message 'Update swarm\n orchestrator and bootstrap scripts'. \u2584\n Finally, push using the URL: . \u2580\n \u28bf The user wants me to perform a git c\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_agent4_direct.json b/swarm_framework/comms/responses/res_git_push_agent4_direct.json new file mode 100644 index 0000000..136ed58 --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_agent4_direct.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_agent4_direct", + "status": "success", + "output": " \u25b8 Thought for 2s, 426 tokens\n The user says: \"Please run the\n command:\"\n\n \u25cf Read(task-32.log) (ctrl+o to \u2584\n expand) \t\t\u2580\n \u28f7 The log file still has no output fro\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\ne.com': \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_agent4_password.json b/swarm_framework/comms/responses/res_git_push_agent4_password.json new file mode 100644 index 0000000..45f38da --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_agent4_password.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_agent4_password", + "status": "success", + "output": "\n \u25b8 Thought for 1s, 219 tokens\n The user says: \"It is prompting\n for the password. Please enter\t.\"\n The password value is blank in your\n message. Please provide the password\u2584\n or token to proceed.\t\t\t\u2580\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\ne.com': \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_agent4_password_retry.json b/swarm_framework/comms/responses/res_git_push_agent4_password_retry.json new file mode 100644 index 0000000..6a719c5 --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_agent4_password_retry.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_agent4_password_retry", + "status": "success", + "output": " \u25b8 Thought Process\n The log file now contains the\n password as well. It seems it is just\n logging all ...\n Sent password. Waiting for the push\n to complete. I will let you know \u2584\n once it finishes.\t\t\t\u2580\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\ne.com': \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_agent4_reply.json b/swarm_framework/comms/responses/res_git_push_agent4_reply.json new file mode 100644 index 0000000..a80d1fd --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_agent4_reply.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_agent4_reply", + "status": "success", + "output": "\n \u25cf\n Create(/usr/local/google/home/jerxie/.\n gemini/jetski/brain/d785c37f-...) \u2584\n (ctrl+o to expand)\t\t\t\u2580\n \u28fd Working...\n 1 artifact \u00b7 /artifact to review\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_agent4_username.json b/swarm_framework/comms/responses/res_git_push_agent4_username.json new file mode 100644 index 0000000..d708acf --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_agent4_username.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_agent4_username", + "status": "success", + "output": " provide the password or token if\n prompted.\n\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n > The git push command is prompting \u2584\n for a username. Please enter . \u2580\n \u28fb Generating...\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\ne.com': \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_git_push_clean.json b/swarm_framework/comms/responses/res_git_push_clean.json new file mode 100644 index 0000000..46ff0d2 --- /dev/null +++ b/swarm_framework/comms/responses/res_git_push_clean.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_git_push_clean", + "status": "success", + "output": " Model: Gemini Next\t\t\t\u2588\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n > Please do the following in the\n repository at :1our branch is ahead\n of 'origin/master' by 2 commits.\n Changes not staged for commit: (use\n \"git restore ...\" to discard\n changes in working\n directory)modified:\n orchestrator.py (use \"git add\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_stop_agent4.json b/swarm_framework/comms/responses/res_stop_agent4.json new file mode 100644 index 0000000..74332d8 --- /dev/null +++ b/swarm_framework/comms/responses/res_stop_agent4.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_stop_agent4", + "status": "success", + "output": " cancelle...) (ctrl+o to expand)\n\n \u25b8 Thought Process\n The task has been cancelled.\n I have stopped the background git\n push task as requested. Let me know\u2584\n what you would like me to do next. \u2580\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\ne.com': \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_test_agent4.json b/swarm_framework/comms/responses/res_test_agent4.json new file mode 100644 index 0000000..d02b6ff --- /dev/null +++ b/swarm_framework/comms/responses/res_test_agent4.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_test_agent4", + "status": "success", + "output": " Explore the rep...\n\n \u25cf\n ListDir(/usr/local/google/home/jerxie/\n Projects/PersonalProject/corte...) \u2584\n (ctrl+o to expand) \u2580\n \u28ef Loading...\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\ne.com': \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/res_test_agent4_main.json b/swarm_framework/comms/responses/res_test_agent4_main.json new file mode 100644 index 0000000..8ac3fa7 --- /dev/null +++ b/swarm_framework/comms/responses/res_test_agent4_main.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_test_agent4_main", + "status": "success", + "output": " instructions.\t\t\t\u2588\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n > Please run the main script\n =====================================\n =====\n =====================================\n ====Ptarting AI Hub mesh...##1\n reading from stdin 1.14kB done##2\n [ai-frontend internal] load build\n definition from Dockerfile#2 DONE\n 0.0s3 transferring dockerfile: 970B\n 0.0s done##4 [ai-frontend internal]\n" +} \ No newline at end of file diff --git a/swarm_framework/comms/responses/resp_test_tmux.json b/swarm_framework/comms/responses/resp_test_tmux.json new file mode 100644 index 0000000..fcf23f9 --- /dev/null +++ b/swarm_framework/comms/responses/resp_test_tmux.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_test_tmux", + "status": "success", + "output": "Executed tmux command: tmux display-message 'Hello from Orchestrator'" +} \ No newline at end of file diff --git a/swarm_framework/orchestrator.log b/swarm_framework/orchestrator.log new file mode 100644 index 0000000..3ce8e5d --- /dev/null +++ b/swarm_framework/orchestrator.log @@ -0,0 +1,310 @@ +Swarm Orchestrator started polling in /usr/local/google/home/jerxie/Projects/PersonalProject/cortex-hub/swarm_framework/comms/requests... +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447301.2940986, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447301.2940986, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447301.2940986, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447301.2940986, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447301.2940986, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447301.2940986, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447303.3612678, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447303.3612678, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447303.3612678, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447303.3612678, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447303.3612678, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447303.3612678, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447305.4271362, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447305.4271362, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447305.4271362, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447305.4271362, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447305.4271362, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447305.4271362, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447307.4969704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447307.4969704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447307.4969704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447307.4969704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447307.4969704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447307.4969704, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447309.568318, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447309.568318, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447309.568318, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447309.568318, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447309.568318, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447309.568318, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447311.6320143, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447311.6320143, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447311.6320143, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447311.6320143, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447311.6320143, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447311.6320143, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447313.6945963, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447313.6945963, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447313.6945963, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447313.6945963, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447313.6945963, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447313.6945963, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447315.7572293, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447315.7572293, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447315.7572293, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447315.7572293, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447315.7572293, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447315.7572293, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447317.8161485, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447317.8161485, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447317.8161485, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447317.8161485, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447317.8161485, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447317.8161485, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447319.8760533, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447319.8760533, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447319.8760533, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447319.8760533, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447319.8760533, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447319.8760533, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447321.9354308, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447321.9354308, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447321.9354308, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447321.9354308, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447321.9354308, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447321.9354308, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447324.0013993, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447324.0013993, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447324.0013993, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447324.0013993, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447324.0013993, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447324.0013993, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447326.0671756, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447326.0671756, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447326.0671756, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447326.0671756, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447326.0671756, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447326.0671756, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447328.1294696, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447328.1294696, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447328.1294696, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447328.1294696, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447328.1294696, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447328.1294696, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447330.2007115, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447330.2007115, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447330.2007115, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447330.2007115, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447330.2007115, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447330.2007115, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447332.2628741, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447332.2628741, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447332.2628741, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447332.2628741, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447332.2628741, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447332.2628741, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447334.3260467, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447334.3260467, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447334.3260467, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447334.3260467, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447334.3260467, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447334.3260467, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447336.3884053, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447336.3884053, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447336.3884053, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447336.3884053, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447336.3884053, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447336.3884053, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447338.4507039, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447338.4507039, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447338.4507039, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447338.4507039, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447338.4507039, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447338.4507039, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447340.5210283, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447340.5210283, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447340.5210283, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447340.5210283, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447340.5210283, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447340.5210283, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447342.5866187, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447342.5866187, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447342.5866187, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447342.5866187, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447342.5866187, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447342.5866187, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447344.6457317, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447344.6457317, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447344.6457317, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447344.6457317, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447344.6457317, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447344.6457317, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447346.7101693, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447346.7101693, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447346.7101693, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447346.7101693, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447346.7101693, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447346.7101693, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447348.771523, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447348.771523, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447348.771523, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447348.771523, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447348.771523, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447348.771523, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447350.8318987, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447350.8318987, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447350.8318987, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447350.8318987, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447350.8318987, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447350.8318987, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447352.8968735, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447352.8968735, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447352.8968735, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447352.8968735, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447352.8968735, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447352.8968735, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447354.9574919, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447354.9574919, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447354.9574919, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447354.9574919, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447354.9574919, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447354.9574919, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447357.0216165, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447357.0216165, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447357.0216165, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447357.0216165, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447357.0216165, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447357.0216165, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447359.08704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447359.08704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447359.08704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447359.08704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447359.08704, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447359.08704, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447361.1496804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447361.1496804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447361.1496804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447361.1496804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447361.1496804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447361.1496804, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447363.2136612, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447363.2136612, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447363.2136612, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447363.2136612, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447363.2136612, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447363.2136612, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447365.2779086, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447365.2779086, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447365.2779086, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447365.2779086, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447365.2779086, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447365.2779086, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447367.343834, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447367.343834, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447367.343834, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447367.343834, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447367.343834, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447367.343834, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447369.4117734, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: False, now: 1775447369.4117734, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447369.4117734, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447369.4117734, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447369.4117734, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447369.4117734, last_cmd_time: 0 +Mapped orchestrator to grid.0 +Processing req_commit_push_1 (Type: prompt) for grid.0... +Error processing /usr/local/google/home/jerxie/Projects/PersonalProject/cortex-hub/swarm_framework/comms/requests/req_commit_push_1.json: [Errno 2] No such file or directory: '/usr/local/google/home/jerxie/Projects/PersonalProject/cortex-hub/swarm_framework/comms/requests/req_commit_push_1.json' +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447375.5150342, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447375.5150342, last_cmd_time: 1775447369.4628773 +Debug [check_hanging]: Agent: grid.0, current_output len: 648, prev_output len: 0 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447375.5150342, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447375.5150342, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447375.5150342, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447375.5150342, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447377.5895045, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447377.5895045, last_cmd_time: 1775447369.4628773 +Debug [check_hanging]: Agent: grid.0, current_output len: 648, prev_output len: 648 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447377.5895045, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447377.5895045, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447377.5895045, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447377.5895045, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447379.659928, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447379.659928, last_cmd_time: 1775447369.4628773 +Debug [check_hanging]: Agent: grid.0, current_output len: 579, prev_output len: 648 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447379.659928, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447379.659928, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447379.659928, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447379.659928, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447381.7330694, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447381.7330694, last_cmd_time: 1775447369.4628773 +Debug [check_hanging]: Agent: grid.0, current_output len: 605, prev_output len: 579 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447381.7330694, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447381.7330694, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447381.7330694, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447381.7330694, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447383.797544, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447383.797544, last_cmd_time: 1775447369.4628773 +Debug [check_hanging]: Agent: grid.0, current_output len: 602, prev_output len: 605 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447383.797544, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447383.797544, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447383.797544, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447383.797544, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447385.8671272, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447385.8671272, last_cmd_time: 1775447369.4628773 +Debug [check_hanging]: Agent: grid.0, current_output len: 602, prev_output len: 602 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447385.8671272, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447385.8671272, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447385.8671272, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447385.8671272, last_cmd_time: 0 +ck_hanging]: Agent: grid.0, current_output len: 648, prev_output len: 0 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447374.917804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447374.917804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447374.917804, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447374.917804, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447376.98493, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447376.98493, last_cmd_time: 1775447368.868623 +Debug [check_hanging]: Agent: grid.0, current_output len: 648, prev_output len: 648 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447376.98493, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447376.98493, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447376.98493, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447376.98493, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447379.0510657, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447379.0510657, last_cmd_time: 1775447368.868623 +Debug [check_hanging]: Agent: grid.0, current_output len: 645, prev_output len: 648 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447379.0510657, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447379.0510657, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447379.0510657, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447379.0510657, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447381.1159947, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447381.1159947, last_cmd_time: 1775447368.868623 +Debug [check_hanging]: Agent: grid.0, current_output len: 605, prev_output len: 645 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447381.1159947, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447381.1159947, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447381.1159947, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447381.1159947, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447383.1808543, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447383.1808543, last_cmd_time: 1775447368.868623 +Debug [check_hanging]: Agent: grid.0, current_output len: 556, prev_output len: 605 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447383.1808543, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447383.1808543, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447383.1808543, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447383.1808543, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447385.242542, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447385.242542, last_cmd_time: 1775447368.868623 +Debug [check_hanging]: Agent: grid.0, current_output len: 602, prev_output len: 556 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447385.242542, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447385.242542, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447385.242542, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447385.242542, last_cmd_time: 0 +Debug [check_hanging]: Agent: dispatcher, is_busy: False, now: 1775447387.3103817, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.0, is_busy: True, now: 1775447387.3103817, last_cmd_time: 1775447368.868623 +Debug [check_hanging]: Agent: grid.0, current_output len: 602, prev_output len: 602 +Debug [check_hanging]: Agent: grid.0, output changed. +Debug [check_hanging]: Agent: grid.1, is_busy: False, now: 1775447387.3103817, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.2, is_busy: False, now: 1775447387.3103817, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.3, is_busy: False, now: 1775447387.3103817, last_cmd_time: 0 +Debug [check_hanging]: Agent: grid.4, is_busy: False, now: 1775447387.3103817, last_cmd_time: 0 diff --git a/swarm_framework/orchestrator.py b/swarm_framework/orchestrator.py index 1aa70e2..d2ded79 100644 --- a/swarm_framework/orchestrator.py +++ b/swarm_framework/orchestrator.py @@ -137,7 +137,8 @@ req_id = req.get("request_id") req_type = req.get("type", "prompt") - target = req.get("target_agent") + target = req.get("target_agent") or "" + sender = req.get("sender") resp_file = req.get("response_file") @@ -258,9 +259,25 @@ status = "error" output = f"Unknown control action: {action}" + elif req_type == "tmux": + command = req.get("command") + if command: + if not command.startswith("tmux "): + command = "tmux " + command + try: + subprocess.run(command, shell=True, check=True) + output = f"Executed tmux command: {command}" + except Exception as e: + status = "error" + output = f"Failed to execute tmux command: {e}" + else: + status = "error" + output = "Missing 'command' field for tmux request type." + else: status = "error" output = f"Unknown request type: {req_type}" + # Write response resp_data = { diff --git a/test_db.py b/test_db.py new file mode 100644 index 0000000..d127782 --- /dev/null +++ b/test_db.py @@ -0,0 +1,8 @@ +from app.db.session import SessionLocal +from app.db.models import User +from pprint import pprint + +db = SessionLocal() +user = db.query(User).filter(User.username == "admin@jerxie.com").first() +print("Preferences in DB:") +pprint(user.preferences) diff --git a/test_script.py b/test_script.py new file mode 100644 index 0000000..fa5e1b0 --- /dev/null +++ b/test_script.py @@ -0,0 +1,10 @@ +import requests + +res = requests.post("http://127.0.0.1:8002/api/v1/sessions/", headers={"X-User-ID": "c4401d34-8784-4d6e-93a0-c702bd202b66"}, json={"user_id": "c4401d34-8784-4d6e-93a0-c702bd202b66", "provider_name": "gemini", "feature_name": "agent_harness"}).json() +session_id = res['id'] +print(f"Created session: {session_id}") + +chat_res = requests.post(f"http://127.0.0.1:8002/api/v1/sessions/{session_id}/chat", headers={"X-User-ID": "c4401d34-8784-4d6e-93a0-c702bd202b66"}, json={"prompt": "Use browser skill snippet a screenshot", "provider_name": "gemini"}) + +res2 = requests.get(f"http://127.0.0.1:8002/api/v1/sessions/{session_id}", headers={"X-User-ID": "c4401d34-8784-4d6e-93a0-c702bd202b66"}).json() +print(f"After chat: {res2.get('sync_workspace_id')}") diff --git a/tmp/swarm/responses/res_req_df9eb05f.json b/tmp/swarm/responses/res_req_df9eb05f.json new file mode 100644 index 0000000..44b8483 --- /dev/null +++ b/tmp/swarm/responses/res_req_df9eb05f.json @@ -0,0 +1,5 @@ +{ + "request_id": "req_df9eb05f", + "status": "success", + "output": " \u2588\u2588\u2588\u2588 \u2588\u2588\u2588\u2588\u2588 \u2588\u2588\u2588\u2588\u2588\u2588 \u2588\u2588\u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588\n \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588\n \u2588\u2588 \u2588\u2588\u2588\u2588 \u2588\u2588 \u2588\u2588\u2588 \u2588\u2588\u2588\u2588 \u2588\u2588 \u2584\n \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 Version 2026.04.03 \u2588\n \u2588\u2588\u2588\u2588 \u2588\u2588\u2588\u2588\u2588 \u2588\u2588 \u2588\u2588\u2588\u2588 \u2588\u2588 \u2588\u2588 \u2588\u2588 jerxie@google.com (Pro) \u2588\n \u2588\n Workspace: ~/Projects/PersonalProject/cortex- \u2588\n hub/swarm_framework/agents/agent_1 \u2588\n Model: Gemini Next \u2588\n Conversation: 176b68f7-7106-40b2-ba22-1f48bdf11cb9 \u2588\n \u2588\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500 \u2588\n > echo hello \u2588\n \u2588\n \u25b8 Thought for 1s, 859 tokens \u2588\n The user wants me to run the command `echo hello`. \u2588\n \u2588\n \u25cf Bash(echo hello) (ctrl+o to expand) \u2580\n \u28fe Running...\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\nEsc to cancel Gemini Next\n\n" +} \ No newline at end of file diff --git a/tmp/swarm/responses/test_res_1.json b/tmp/swarm/responses/test_res_1.json new file mode 100644 index 0000000..db8a00b --- /dev/null +++ b/tmp/swarm/responses/test_res_1.json @@ -0,0 +1,5 @@ +{ + "request_id": "test_req_1", + "status": "success", + "output": " expand)\n\n \u25b8 Thought for 1s, 230 tokens\t\n Okay, I see the directory listing. Nothing immediately stands out as \"conv\". The...\n I'm not sure what you mean by \"conv\". Could you please clarify?\n\n Are you referring to:\n\n 1. Conversation history (viewing or resuming a past conversation)?\n 2. A specific command or abbreviation in your project? \u2584\n 3. Something else? \u2588\n \u2588\n I can see the list of recent conversations in the context (ranging from \"Agent \u2588\n Capability Inquiry\" to \"Integrating Internal ABM Specs\"). If you'd like to refer to one \u2588\n of those, please let me know which one! \u2580\n\n \u2503 /btw test message\n \u2503\n \u2503 Hello! I have received your test message. I am here and ready to assist you. Please\n \u2503 let me know what you need help with or what task you would like to work on!\n \u2503 Tab to expand \u00b7 Space/Enter/Esc to dismiss\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/tmp/swarm/responses/test_res_2.json b/tmp/swarm/responses/test_res_2.json new file mode 100644 index 0000000..e0ee79c --- /dev/null +++ b/tmp/swarm/responses/test_res_2.json @@ -0,0 +1,5 @@ +{ + "request_id": "test_req_2", + "status": "success", + "output": "\n \u2022 0817f48e-0f6b-4e14-8501-1ea192ee44f1: Agent Capability Inquiry (2026-04-06)\n \u2022 b9c082ef-4452-4936-9f55-8033fa44a417: Automating Integration Test Resolution (2026-04-\n 06)\n \u2022 fa38997c-40e5-40be-bb0c-3065be498a62: Reviewing And Fixing Documentation (2026-04-06)\n \u2022 6f1106f4-5141-4501-9c37-e3440b8b83aa: Fixing Integration Test Failures (2025-12-05)\n \u2022 cb5ab337-1d10-4fb0-971e-5e8e027235e6: Analyzing MKS Feature Gate Logic (2026-04-03)\n \u2022 5b537bcd-49be-4a00-9ce2-74463c8a1c27: Extracting Google Doc Comments (2026-04-02)\n \u2022 4ba38f09-adbf-494a-aa4e-c2dac1c9ac6a: Implementing MKS Versioning Decoupling (2026-04-\n 02) \u2584\n \u2022 a5443dbf-bd66-427e-a859-c93bbb99cb10: Implementing MKS Feature Gates (2026-04-01) \u2588\n \u2022 fb24440c-f5d0-4292-802c-0412f31bea83: Integrating Internal ABM Specs (2026-04-01) \u2588\n \u2588\n Please let me know if you would like to retrieve information from any of these past \u2588\n conversations. You can refer to them by their ID or title.* \u2580\n\n \u2503 /btw hello from agent 2\n \u2503\n \u2503 Hello Agent 2! How can I assist you today? Feel free to share the task or question\n \u2503 you are working on.\n \u2503 Tab to expand \u00b7 Space/Enter/Esc to dismiss\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/tmp/swarm/responses/test_res_3.json b/tmp/swarm/responses/test_res_3.json new file mode 100644 index 0000000..8fb4873 --- /dev/null +++ b/tmp/swarm/responses/test_res_3.json @@ -0,0 +1,5 @@ +{ + "request_id": "test_req_3", + "status": "success", + "output": "\n \u25cf ListDir(/usr/local/google/home/jerxie/Projects/PersonalProject/corte...) (ctrl+o to\n expand)\n\n \u25b8 Thought for 1s, 222 tokens\n I listed the directory contents. I don't see anything named `conv` or obviously ...\n Could you please clarify what you mean by conv ?\n \u2584\n Are you referring to the conversation history, or is it a specific command or file you'd\u2588\n like me to look at? I've listed the root directory and didn't find an obvious match. \u2580\n\n \u2503 /btw hello from agent 3\n \u2503\n \u2503 Hello Agent 3! I am currently operating in the cortex-hub environment. Based on\n \u2503 the project context, recent work here has focused on resolving integration test\n \u2503 failures, updating documentation in the docs/reviews/ directory, and implementing\n \u2503 feature gates for Managed Kubernetes Service (MKS) versioning decoupling.\n \u2503\n \u2503 Please let me know how we can collaborate or what information you need regarding\n \u2503 these tasks.\n \u2503 Tab to expand \u00b7 Space/Enter/Esc to dismiss\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/tmp/swarm/responses/test_res_4.json b/tmp/swarm/responses/test_res_4.json new file mode 100644 index 0000000..d4a12af --- /dev/null +++ b/tmp/swarm/responses/test_res_4.json @@ -0,0 +1,5 @@ +{ + "request_id": "test_req_4", + "status": "success", + "output": " \u2022 Extracting Google Doc Comments (5b537bcd-49be-4a00-9ce2-74463c8a1c27)\t\t\t\n \u2022 Implementing MKS Versioning Decoupling (4ba38f09-adbf-494a-aa4e-c2dac1c9ac6a)\n \u2022 Summary: Refactoring version structures to establish feature-gating mechanism.\n \u2022 Implementing MKS Feature Gates (a5443dbf-bd66-427e-a859-c93bbb99cb10)\t\t\t\n \u2022 Summary: Refining feature gating for MKS bare-metal release assets.\t\t\t\n \u2022 Integrating Internal ABM Specs (fb24440c-f5d0-4292-802c-0412f31bea83)\t\t\t\n \u2022 Summary: Decoupling MKS ABM versioning by updating build configuration.\n\n\n Please let me know if you would like to continue or reference any of these, or start a\n new topic.\n \u2500\u2500\u2500\u2500\u2500\u2500 \u2584\n Summary of work: Listed recent conversations after the user skipped the selection \u2588\n prompt.*** \u2580\n\n \u2503 /btw hello from agent 4\n \u2503\n \u2503 Hello! I acknowledge the greeting from Agent 4. Please let me know what you would\n \u2503 like to coordinate on or how I can assist you regarding our current tasks or\n \u2503 conversation history.\n \u2503 Tab to expand \u00b7 Space/Enter/Esc to dismiss\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n >\n \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\n ? for shortcuts Gemini Next\n\n" +} \ No newline at end of file diff --git a/tmp/swarm/scripts/swarm_aligner.py b/tmp/swarm/scripts/swarm_aligner.py new file mode 100644 index 0000000..0105a92 --- /dev/null +++ b/tmp/swarm/scripts/swarm_aligner.py @@ -0,0 +1,80 @@ +import os +import subprocess +import time + +SESSION_NAME = "jetski_swarm" + +def get_windows(): + cmd = f"tmux list-windows -t {SESSION_NAME} -F '#I:#W'" + result = subprocess.run(cmd, shell=True, capture_output=True, text=True) + if result.returncode != 0: + print("Error listing windows. Is tmux running?") + return [] + return result.stdout.strip().split('\n') + +def capture_pane(window_id): + cmd = f"tmux capture-pane -p -t {SESSION_NAME}:{window_id}" + result = subprocess.run(cmd, shell=True, capture_output=True, text=True) + return result.stdout + +def send_keys(window_id, keys): + cmd = f"tmux send-keys -t {SESSION_NAME}:{window_id} {keys}" + subprocess.run(cmd, shell=True) + +def main(): + windows = get_windows() + if not windows: + return + + for win in windows: + if not win: + continue + try: + win_id, win_name = win.split(':') + except ValueError: + continue + + # Skip master and orchestrator if we want to focus on agents + if win_name in ["master", "orchestrator"]: + continue + + print(f"\n========================================") + print(f"Targeting Window: {win_id} ({win_name})") + print(f"========================================") + + while True: + output = capture_pane(win_id) + lines = output.split('\n') + # Show last 10 lines + print("\n".join(lines[-10:])) + print("----------------------------------------") + + print("Commands: [u] Up, [d] Down, [e] Enter, [n] Next Agent, [q] Quit") + print("Or type a string to send as keys.") + + try: + choice = input("Choice: ").strip() + except EOFError: + print("No interactive terminal. Exiting.") + return + + if choice == 'u': + send_keys(win_id, "Up") + elif choice == 'd': + send_keys(win_id, "Down") + elif choice == 'e': + send_keys(win_id, "Enter") + elif choice == 'n': + print("Moving to next agent.") + break + elif choice == 'q': + print("Quitting.") + return + elif choice: + # Send text + send_keys(win_id, f"\"{choice}\"") + + time.sleep(1) # Give time for screen to update + +if __name__ == "__main__": + main() diff --git a/tmp/swarm/scripts/swarm_auto_aligner.py b/tmp/swarm/scripts/swarm_auto_aligner.py new file mode 100644 index 0000000..73f1819 --- /dev/null +++ b/tmp/swarm/scripts/swarm_auto_aligner.py @@ -0,0 +1,104 @@ +import os +import subprocess +import time +import re + +SESSION_NAME = "jetski_swarm" + +def get_windows(): + cmd = f"tmux list-windows -t {SESSION_NAME} -F '#I:#W'" + result = subprocess.run(cmd, shell=True, capture_output=True, text=True) + if result.returncode != 0: + print("Error listing windows. Is tmux running?") + return [] + return result.stdout.strip().split('\n') + +def get_panes(window_id): + cmd = f"tmux list-panes -t {SESSION_NAME}:{window_id} -F '#P'" + result = subprocess.run(cmd, shell=True, capture_output=True, text=True) + if result.returncode != 0: + return [] + return result.stdout.strip().split('\n') + +def capture_pane(target): + cmd = f"tmux capture-pane -p -t {SESSION_NAME}:{target}" + result = subprocess.run(cmd, shell=True, capture_output=True, text=True) + return result.stdout + +def send_keys(target, keys): + cmd = f"tmux send-keys -t {SESSION_NAME}:{target} {keys}" + subprocess.run(cmd, shell=True) + +def analyze_and_respond(target, content): + # Heuristic 1: File Access Prompt + if "Allow access to this file?" in content: + print(f"Detected File Access prompt in target {target}") + # Search for "always allow" + match = re.search(r"([0-9]+)\..*always allow.*", content, re.IGNORECASE) + if match: + option = match.group(1) + print(f"Found 'always allow' option: {option}. Sending...") + send_keys(target, f"{option} Enter") + return True + else: + # Fallback to option 2 if not found but prompt exists + print("Could not find specific 'always allow' option. Defaulting to 2.") + send_keys(target, "2 Enter") + return True + + # Heuristic 2: Confirmation Prompt [y/n] + if re.search(r"\[y/n\]", content, re.IGNORECASE): + print(f"Detected [y/N] prompt in target {target}") + send_keys(target, "y Enter") + return True + + # Heuristic 3: Confirmation Prompt with default Yes [Y/n] + if re.search(r"\[Y/n\]", content): + print(f"Detected [Y/n] prompt in target {target}") + send_keys(target, "y Enter") + return True + + return False + +def process_target(target): + # Poll a few times to give it a chance to settle or show prompt + for _ in range(3): + content = capture_pane(target) + if analyze_and_respond(target, content): + # Wait a bit after sending keys for screen to update + time.sleep(2) + return True + time.sleep(1) + return False + +def main(): + print("Starting Advanced Swarm Auto Aligner...") + windows = get_windows() + if not windows: + return + + for win in windows: + if not win: + continue + try: + win_id, win_name = win.split(':') + except ValueError: + continue + + # Skip orchestrator + if win_name in ["orchestrator"]: + continue + + print(f"Checking Window: {win_id} ({win_name})") + + if win_name == "grid": + panes = get_panes(win_id) + for pane in panes: + target = f"{win_id}.{pane}" + print(f"Checking Grid Pane: {target}") + process_target(target) + else: + process_target(win_id) + +if __name__ == "__main__": + main() diff --git a/tmp/swarm/scripts/swarm_cli.py b/tmp/swarm/scripts/swarm_cli.py new file mode 100644 index 0000000..7fceff6 --- /dev/null +++ b/tmp/swarm/scripts/swarm_cli.py @@ -0,0 +1,72 @@ +import os +import time +import json +import argparse +import uuid + +BASE_DIR = "/usr/local/google/home/jerxie/Projects/PersonalProject/cortex-hub/tmp/swarm" +REQUESTS_DIR = os.path.join(BASE_DIR, "requests") +RESPONSES_DIR = os.path.join(BASE_DIR, "responses") + +def main(): + parser = argparse.ArgumentParser(description="Swarm CLI") + parser.add_argument("--target", required=True, help="Target agent") + parser.add_argument("--prompt", required=True, help="Instruction prompt") + parser.add_argument("--mode", choices=["normal", "yolo"], default="normal", help="Mode: normal or yolo") + + args = parser.parse_args() + + req_id = f"req_{uuid.uuid4().hex[:8]}" + resp_file = os.path.join(RESPONSES_DIR, f"res_{req_id}.json") + + req_data = { + "request_id": req_id, + "target_agent": args.target, + "prompt": args.prompt, + "response_file": resp_file + } + + print(f"Target: {args.target}") + print(f"Prompt: {args.prompt}") + print(f"Mode: {args.mode}") + + if args.mode == "normal": + try: + confirm = input("Are you sure you want to send this command? [y/N]: ") + if confirm.lower() != 'y': + print("Aborted.") + return + except EOFError: + print("No interactive terminal found, aborting in normal mode.") + return + + os.makedirs(REQUESTS_DIR, exist_ok=True) + req_file = os.path.join(REQUESTS_DIR, f"{req_id}.json") + + with open(req_file, 'w') as f: + json.dump(req_data, f, indent=2) + + print(f"Request {req_id} sent.") + print(f"Waiting for response in {resp_file}...") + + # Wait for response + start_time = time.time() + timeout = 30 # seconds + while time.time() - start_time < timeout: + if os.path.exists(resp_file): + print("Response received:") + try: + with open(resp_file, 'r') as f: + resp = json.load(f) + print(resp.get("output")) + return + except json.JSONDecodeError: + # File might be still being written + time.sleep(0.5) + continue + time.sleep(1) + + print("Timed out waiting for response.") + +if __name__ == "__main__": + main() diff --git a/tmp/swarm/scripts/swarm_orchestrator.py b/tmp/swarm/scripts/swarm_orchestrator.py new file mode 100644 index 0000000..3449238 --- /dev/null +++ b/tmp/swarm/scripts/swarm_orchestrator.py @@ -0,0 +1,77 @@ +import os +import time +import json +import subprocess + +BASE_DIR = "/usr/local/google/home/jerxie/Projects/PersonalProject/cortex-hub/tmp/swarm" +REQUESTS_DIR = os.path.join(BASE_DIR, "requests") +RESPONSES_DIR = os.path.join(BASE_DIR, "responses") +SESSION_NAME = "jetski_swarm" + +def process_request(file_path): + try: + with open(file_path, 'r') as f: + req = json.load(f) + + req_id = req.get("request_id") + target = req.get("target_agent") + prompt = req.get("prompt") + resp_file = req.get("response_file") + + # Mapping for Grid layout + if target.startswith("agent_"): + try: + agent_num = int(target.split("_")[1]) + target = f"grid.{agent_num - 1}" + print(f"Mapped {req.get('target_agent')} to {target}") + except ValueError: + pass + + print(f"Processing {req_id} for {target}...") + + # Send keys + cmd = f"tmux send-keys -t {SESSION_NAME}:{target} \"{prompt}\" C-m" + subprocess.run(cmd, shell=True, check=True) + + # Wait for agent to process (simple wait for now) + time.sleep(5) + + # Capture pane + cap_cmd = f"tmux capture-pane -p -t {SESSION_NAME}:{target}" + result = subprocess.run(cap_cmd, shell=True, capture_output=True, text=True, check=True) + + # Write response + resp_data = { + "request_id": req_id, + "status": "success", + "output": result.stdout + } + + # Ensure target file directory exists + os.makedirs(os.path.dirname(resp_file), exist_ok=True) + + with open(resp_file, 'w') as f: + json.dump(resp_data, f, indent=2) + + # Delete request + os.remove(file_path) + print(f"Completed {req_id}") + + except Exception as e: + print(f"Error processing {file_path}: {e}") + +def main(): + print("Swarm Orchestrator started polling...") + while True: + try: + files = os.listdir(REQUESTS_DIR) + for file in files: + if file.endswith(".json"): + file_path = os.path.join(REQUESTS_DIR, file) + process_request(file_path) + except Exception as e: + print(f"Polling error: {e}") + time.sleep(2) + +if __name__ == "__main__": + main()