windmill-labs / windmill

Open-source developer platform to power your entire infra and turn scripts into webhooks, workflows and UIs. Fastest workflow engine (13x vs Airflow). Open-source alternative to Retool and Temporal.
https://windmill.dev
Other
9.86k stars 462 forks source link

Error: "requiring status to be parsable as FlowStatus" when a flow triggered using run_flow_async #4172

Open b-liberman opened 2 months ago

b-liberman commented 2 months ago

I trigger a very simple flow with just an action that echoes the input string. I do it like this:

wmill.run_flow_async(path=FLOW_TO_TRIGGER, args={"msg": payload}) Here is the code for the action:

def main(msg: str):
    print("------------- start echo ------------")
    print(msg)
    print("------------- end echo ------------")
    return {'step': 1}

I am getting the following error:

{ "error": { "name": "InternalErr", "message": "Internal: requiring status to be parsable as FlowStatus: Error(\"missing fieldstep\", line: 1, column: 108)" } }

If I execute this flow manually it succeeds without an error.

Thanks for any help

Boris

P.S. here is the complete flow execution log

`Auto scroll job=01911318-ae9b-9335-6fde-ff254250482a tag=python3 worker=wk-default-q4sqh-X53WG hostname=windmill-workers-6b4f68c9f7-q4sqh

--- PYTHON CODE EXECUTION ---

------------- start echo ------------ {"age": 28} ------------- end echo ------------Unexpected error during job execution: Object { "message": String("Internal: requiring status to be parsable as FlowStatus: Error(\"missing field step\", line: 1, column: 108)"), "name": String("InternalErr"), }`

rubenfiszel commented 2 months ago

Investigating, thanks for the report

On Fri, Aug 2, 2024 at 2:55 PM b-liberman @.***> wrote:

I trigger a very simple flow with just an action that echoes the input string. I do it like this:

wmill.run_flow_async(path=FLOW_TO_TRIGGER, args={"msg": payload}) Here is the code for the action:

def main(msg: str): print("------------- start echo ------------") print(msg) print("------------- end echo ------------") return {'step': 1}

I am getting the following error:

{ "error": { "name": "InternalErr", "message": "Internal: requiring status to be parsable as FlowStatus: Error(\"missing field step\", line: 1, column: 108)" } }

Thanks for any help

Boris

— Reply to this email directly, view it on GitHub https://github.com/windmill-labs/windmill/issues/4172, or unsubscribe https://github.com/notifications/unsubscribe-auth/AACDJAFFCJTXPHNCYNNKQQDZPN6UPAVCNFSM6AAAAABL4P4CGWVHI2DSMVQWIX3LMV43ASLTON2WKOZSGQ2DIOJQGY4DENQ . You are receiving this because you are subscribed to this thread.Message ID: @.***>

rubenfiszel commented 2 months ago

Should be fixed on very latest commit available in tag :main and :latest in 15 minutes