diff --git a/laborious/workflows/sub_workflows/prediction_process.py b/laborious/workflows/sub_workflows/prediction_process.py index 3493b59..7c4d702 100644 --- a/laborious/workflows/sub_workflows/prediction_process.py +++ b/laborious/workflows/sub_workflows/prediction_process.py @@ -146,7 +146,7 @@ class PredictionProcess: return # Request MLFlow model transformation - transformed_data = await workflow.execute_local_activity_method( + transformed_data = await workflow.execute_activity_method( Activities.request_transform, {**metadata, 'data': data, 'model_name': model_name, 'model_config': model_config}, retry_policy=retry_policy, @@ -191,7 +191,7 @@ class PredictionProcess: ): return - predicted_data = await workflow.execute_local_activity_method( + predicted_data = await workflow.execute_activity_method( Activities.request_predict, { **metadata,