@@ -678,8 +678,8 @@ def set_dependency_usage(self, job_id: str, *, user_id: Optional[str] = None, de
678
678
def set_proxy_user (self , job_id : str , proxy_user : str ) -> None :
679
679
self ._update (job_id = job_id , proxy_user = proxy_user )
680
680
681
- def set_application_id (self , job_id : str , application_id : str ) -> JobDict :
682
- return self ._update (job_id = job_id , application_id = application_id )
681
+ def set_application_id (self , job_id : str , application_id : str ) -> None :
682
+ self ._update (job_id = job_id , application_id = application_id )
683
683
684
684
def set_results_metadata (
685
685
self , job_id : str , costs : Optional [float ], usage : dict , results_metadata : Dict [str , Any ]
@@ -1025,8 +1025,9 @@ def get_active_jobs(
1025
1025
require_application_id = True ,
1026
1026
)
1027
1027
1028
- def set_results_metadata (self , job_id , user_id , costs : Optional [float ], usage : dict ,
1029
- results_metadata : Dict [str , Any ]):
1028
+ def set_results_metadata (
1029
+ self , job_id , user_id , costs : Optional [float ], usage : dict , results_metadata : Dict [str , Any ]
1030
+ ) -> None :
1030
1031
if self .zk_job_registry :
1031
1032
self .zk_job_registry .patch (job_id = job_id , user_id = user_id ,
1032
1033
** dict (results_metadata , costs = costs , usage = usage ))
0 commit comments