Spaces:
Running
Running
fix: Fixed the namespace in launcher
Browse files
huggingface_overlay/cloud_pipelines_backend/launchers/huggingface_launchers.py
CHANGED
|
@@ -276,10 +276,10 @@ exit "$exit_code"
|
|
| 276 |
# flavor=...,
|
| 277 |
)
|
| 278 |
|
| 279 |
-
_logger.
|
| 280 |
launched_container = LaunchedHuggingFaceJobContainer(
|
| 281 |
id=job.id,
|
| 282 |
-
namespace=
|
| 283 |
job=job,
|
| 284 |
output_uris=output_uris,
|
| 285 |
log_uri=log_uri,
|
|
@@ -392,7 +392,9 @@ class LaunchedHuggingFaceJobContainer(interfaces.LaunchedContainer):
|
|
| 392 |
def launcher_error_message(self) -> str | None:
|
| 393 |
if self._job.status.message:
|
| 394 |
# TODO: Check what kind of messages this returns and when.
|
| 395 |
-
_logger.
|
|
|
|
|
|
|
| 396 |
return self._job.status.message
|
| 397 |
return None
|
| 398 |
|
|
@@ -406,7 +408,10 @@ class LaunchedHuggingFaceJobContainer(interfaces.LaunchedContainer):
|
|
| 406 |
.download_as_text()
|
| 407 |
)
|
| 408 |
except Exception as ex:
|
| 409 |
-
_logger.warning(
|
|
|
|
|
|
|
|
|
|
| 410 |
return "\n".join(
|
| 411 |
self._get_api_client().fetch_job_logs(
|
| 412 |
job_id=self._id,
|
|
|
|
| 276 |
# flavor=...,
|
| 277 |
)
|
| 278 |
|
| 279 |
+
_logger.info(f"Launched HF Job {job.id=}, {job.url=}")
|
| 280 |
launched_container = LaunchedHuggingFaceJobContainer(
|
| 281 |
id=job.id,
|
| 282 |
+
namespace=self._namespace,
|
| 283 |
job=job,
|
| 284 |
output_uris=output_uris,
|
| 285 |
log_uri=log_uri,
|
|
|
|
| 392 |
def launcher_error_message(self) -> str | None:
|
| 393 |
if self._job.status.message:
|
| 394 |
# TODO: Check what kind of messages this returns and when.
|
| 395 |
+
_logger.info(
|
| 396 |
+
f"launcher_error_message: {self._id=}: {self._job.status.message=}"
|
| 397 |
+
)
|
| 398 |
return self._job.status.message
|
| 399 |
return None
|
| 400 |
|
|
|
|
| 408 |
.download_as_text()
|
| 409 |
)
|
| 410 |
except Exception as ex:
|
| 411 |
+
_logger.warning(
|
| 412 |
+
f"get_log: {self._id=}: Error getting log from URI: {self._log_uri}",
|
| 413 |
+
ex,
|
| 414 |
+
)
|
| 415 |
return "\n".join(
|
| 416 |
self._get_api_client().fetch_job_logs(
|
| 417 |
job_id=self._id,
|