File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
src/sagemaker/remote_function Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 35
35
36
36
from sagemaker .session import Session
37
37
from sagemaker .s3 import s3_path_join
38
- from sagemaker .remote_function .job import _Job , _JobSettings
39
- from sagemaker .remote_function .job import _RunInfo
38
+ from sagemaker .remote_function .job import _JobSettings , _Job , _RunInfo
40
39
from sagemaker .remote_function import logging_config
41
40
from sagemaker .utils import name_from_base , base_from_name
42
41
from sagemaker .remote_function .spark_config import SparkConfig
43
42
from sagemaker .remote_function .custom_file_filter import CustomFileFilter
43
+ from sagemaker .telemetry .telemetry_logging import _telemetry_emitter
44
+ from sagemaker .telemetry .constants import Feature
44
45
45
46
_API_CALL_LIMIT = {
46
47
"SubmittingIntervalInSecs" : 1 ,
57
58
58
59
logger = logging_config .get_logger ()
59
60
60
-
61
+ @ _telemetry_emitter ( feature = Feature . REMOTE_FUNCTION , func_name = "remote_function.remote" )
61
62
def remote (
62
63
_func = None ,
63
64
* ,
You can’t perform that action at this time.
0 commit comments