2424@events .init_command_line_parser .add_listener
2525def _ (parser : LocustArgumentParser ) -> None :
2626 parser .add_argument (
27- "--function_uid " ,
27+ "--function-uuid " ,
2828 type = str ,
2929 required = True ,
3030 help = "The function UUID to test" ,
@@ -47,7 +47,7 @@ class WebApiUser(OsparcWebUserBase):
4747 @task
4848 def run_function (self ) -> None :
4949
50- function_uid = self .environment .parsed_options .function_uid
50+ function_uuid = self .environment .parsed_options .function_uuid
5151 job_input_schema = json .loads (self .environment .parsed_options .body_json_schema )
5252 max_poll_time = timedelta (
5353 seconds = self .environment .parsed_options .max_poll_time_seconds
@@ -56,15 +56,15 @@ def run_function(self) -> None:
5656 # run function
5757 job_input_faker = jsf .JSF (job_input_schema )
5858 response = self .authenticated_post (
59- url = f"/v0/functions/{ function_uid } :run" ,
59+ url = f"/v0/functions/{ function_uuid } :run" ,
6060 json = job_input_faker .generate (),
6161 headers = {
6262 "x-simcore-parent-project-uuid" : "null" ,
6363 "x-simcore-parent-node-id" : "null" ,
6464 },
6565 )
6666 response .raise_for_status ()
67- job_uid = response .json ().get ("uid" )
67+ job_uuid = response .json ().get ("uid" )
6868
6969 # wait for the job to complete
7070 for attempt in Retrying (
@@ -75,11 +75,11 @@ def run_function(self) -> None:
7575 ):
7676 with attempt :
7777 job_status_response = self .authenticated_get (
78- f"/v0/function_jobs/{ job_uid } /status"
78+ f"/v0/function_jobs/{ job_uuid } /status"
7979 )
8080 job_status_response .raise_for_status ()
8181 status = job_status_response .json ().get ("status" )
8282 if status != "SUCCESS" :
8383 raise ValueError (
84- f"Function job ({ job_uid = } ) for function ({ function_uid = } ) returned { status = } "
84+ f"Function job ({ job_uuid = } ) for function ({ function_uuid = } ) returned { status = } "
8585 )
0 commit comments