@@ -129,6 +129,7 @@ def triggers_fire(name: str) -> None:
129129 """
130130 from rich .console import Console
131131
132+ from bernstein .cli .helpers import server_post
132133 from bernstein .core .models import TriggerEvent
133134 from bernstein .core .trigger_manager import TriggerManager
134135
@@ -185,24 +186,21 @@ def triggers_fire(name: str) -> None:
185186 console .print ("[dim]Cancelled.[/dim]" )
186187 return
187188
188- # Create tasks via HTTP
189- import httpx
190-
189+ # Create tasks via HTTP using proper server helper
191190 for payload in task_payloads :
192- try :
193- resp = httpx .post ("http://127.0.0.1:8052/tasks" , json = payload , timeout = 5 )
194- if resp .status_code in (200 , 201 ):
195- task_id = resp .json ().get ("id" , "unknown" )
196- console .print (f"[green]Created task { task_id } [/green]" )
197- mgr .record_fire (
198- trigger_name = name ,
199- source = target .source ,
200- task_id = task_id ,
201- dedup_key = "manual" ,
202- summary = "Manual fire from CLI" ,
203- )
204- else :
205- console .print (f"[red]Failed to create task: { resp .status_code } { resp .text } [/red]" )
206- except httpx .ConnectError :
207- console .print ("[red]Cannot connect to task server at http://127.0.0.1:8052[/red]" )
208- raise SystemExit (1 ) # noqa: B904
191+ result = server_post ("/tasks" , payload )
192+ if result is None :
193+ from bernstein .cli .errors import server_unreachable
194+
195+ server_unreachable ().print ()
196+ raise SystemExit (1 )
197+
198+ task_id = result .get ("id" , "unknown" )
199+ console .print (f"[green]Created task { task_id } [/green]" )
200+ mgr .record_fire (
201+ trigger_name = name ,
202+ source = target .source ,
203+ task_id = task_id ,
204+ dedup_key = "manual" ,
205+ summary = "Manual fire from CLI" ,
206+ )
0 commit comments