Skip to content

Commit df9e287

Browse files
committed
Update mock
1 parent c1a625d commit df9e287

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

workflow-notifier/mocks/argo_workflow_mock.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,19 @@ def trigger_fencilla():
9696
return jsonify({"message": "Fencilla triggered"}), 200
9797

9898

99+
@flask_app.route("/trigger-rain-drop", methods=["POST"])
100+
def trigger_rain_drop():
101+
data = request.get_json()
102+
print(f"Received rain-drop trigger: {data}")
103+
workflow_id = _extract_workflow_id(data)
104+
if workflow_id is None:
105+
return jsonify({"error": "workflowId missing"}), 400
106+
107+
payload = {"rain": random.random() < 0.2}
108+
threading.Thread(target=_run_workflow, args=(workflow_id, payload)).start()
109+
return jsonify({"message": "Rain-drop triggered"}), 200
110+
111+
99112
@flask_app.route("/trigger-thermal-reading", methods=["POST"])
100113
def trigger_thermal_reading():
101114
data = request.get_json()

0 commit comments

Comments
 (0)