|
34 | 34 | from granulate_utils.linux.ns import is_running_in_init_pid
|
35 | 35 | from granulate_utils.linux.process import is_process_running
|
36 | 36 | from granulate_utils.metadata.cloud import get_aws_execution_env
|
37 |
| -from granulate_utils.metadata.databricks_client import DBXWebUIEnvWrapper, get_name_from_metadata |
38 | 37 | from psutil import NoSuchProcess, Process
|
39 | 38 | from requests import RequestException, Timeout
|
40 | 39 |
|
@@ -1043,18 +1042,18 @@ def main() -> None:
|
1043 | 1042 | # assume we run in the root cgroup (when containerized, that's our view)
|
1044 | 1043 | usage_logger = CgroupsUsageLogger(logger, "/") if args.log_usage else NoopUsageLogger()
|
1045 | 1044 |
|
1046 |
| - if args.databricks_job_name_as_service_name: |
1047 |
| - # "databricks" will be the default name in case of failure with --databricks-job-name-as-service-name flag |
1048 |
| - args.service_name = "databricks" |
1049 |
| - dbx_web_ui_wrapper = DBXWebUIEnvWrapper(logger) |
1050 |
| - dbx_metadata = dbx_web_ui_wrapper.all_props_dict |
1051 |
| - if dbx_metadata is not None: |
1052 |
| - service_suffix = get_name_from_metadata(dbx_metadata) |
1053 |
| - if service_suffix is not None: |
1054 |
| - args.service_name = f"databricks-{service_suffix}" |
1055 |
| - |
1056 |
| - if remote_logs_handler is not None: |
1057 |
| - remote_logs_handler.update_service_name(args.service_name) |
| 1045 | + # if args.databricks_job_name_as_service_name: |
| 1046 | + # # "databricks" will be the default name in case of failure with --databricks-job-name-as-service-name flag |
| 1047 | + # args.service_name = "databricks" |
| 1048 | + # dbx_web_ui_wrapper = DBXWebUIEnvWrapper(logger) |
| 1049 | + # dbx_metadata = dbx_web_ui_wrapper.all_props_dict |
| 1050 | + # if dbx_metadata is not None: |
| 1051 | + # service_suffix = get_name_from_metadata(dbx_metadata) |
| 1052 | + # if service_suffix is not None: |
| 1053 | + # args.service_name = f"databricks-{service_suffix}" |
| 1054 | + # |
| 1055 | + # if remote_logs_handler is not None: |
| 1056 | + # remote_logs_handler.update_service_name(args.service_name) |
1058 | 1057 |
|
1059 | 1058 | try:
|
1060 | 1059 | logger.info(
|
|
0 commit comments