adam/open-swe
1
0
Fork 0
mirror of https://github.com/Sea-Haven-Industries/open-swe.git synced 2026-10-04 10:12:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: queue Slack follow-up messages instead of interrupting active runs (#1050)

Browse source 
Co-authored-by: Brace Sproul <braceasproul@gmail.com>
This commit is contained in:
Aran Yogesh 2026-03-19 13:59:25 -07:00 • committed by GitHub
parent 352f787989
commit ea27978d51
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 18 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
agent/webapp.py
View file

@ -807,6 +807,24 @@ async def process_slack_mention(event_data: dict[str, Any], repo_config: dict[st
langgraph_client = get_client(url=LANGGRAPH_URL) langgraph_client = get_client(url=LANGGRAPH_URL)
await _upsert_slack_thread_repo_metadata(thread_id, repo_config, langgraph_client) await _upsert_slack_thread_repo_metadata(thread_id, repo_config, langgraph_client)
thread_active = await is_thread_active(thread_id)
if thread_active:
logger.info(
"Thread %s is active, queuing Slack message for middleware pickup",
thread_id,
)
queued_payload = {"text": prompt, "image_urls": []}
queued = await queue_message_for_thread(
thread_id=thread_id,
message_content=queued_payload,
)
if queued:
logger.info("Slack message queued for thread %s", thread_id)
else:
logger.error("Failed to queue Slack message for thread %s", thread_id)
return
run = await langgraph_client.runs.create( run = await langgraph_client.runs.create(
thread_id, thread_id,
"agent", "agent",