in modules/python/src/datapreprocessing/ray_utils.py [0:0]
def __init__(
self,
ray_cluster_host: str,
ray_resources: Dict[str, Any],
ray_runtime: Dict[str, Any],
package_name: str,
module_name: str,
class_name: str,
method_name: str,
df: pd.DataFrame,
gcs_bucket: str,
gcs_folder: str,