import json
import os
import sys

context = json.load(sys.stdin)
# Edge passes phase input directly; the local/cloud runner uses RunnerContext.
payload = context if os.environ.get("RIPPFLOW_RUN_ID") else context.get("payload")
print(json.dumps({"outcome": "completed", "payload": payload}))