Method upload_logfile

agentops/client/api/versions/v4.py:108–145

Upload a logfile to the V4 API. Args: body: The logfile content to upload trace_id: The trace ID associated with the logfile Returns: Dictionary containing upload response data Raises: ApiServerException: If the uplo

(self, body: Union[str, bytes], trace_id: str)

            raise ApiServerException(f"Failed to upload object: {e}")

    def upload_logfile(self, body: Union[str, bytes], trace_id: str) -> Dict[str, Any]:
        """
        Upload a logfile to the V4 API.

        Args:
            body: The logfile content to upload
            trace_id: The trace ID associated with the logfile

        Returns:
            Dictionary containing upload response data

        Raises:
            ApiServerException: If the upload fails
        """
        try:
            # Convert bytes to string for consistency with test expectations
            if isinstance(body, bytes):
                body = body.decode("utf-8")

            headers = {**self.prepare_headers(), "Trace-Id": str(trace_id)}
            response = self.post("/v4/logs/upload/", body, headers)

            if response.status_code != 200:
                error_msg = f"Upload failed: {response.status_code}"
                try:
                    error_data = response.json()
                    if "error" in error_data:
                        error_msg = error_data["error"]
                except:
                    pass
                raise ApiServerException(error_msg)

            try:
                return response.json()
            except Exception as e:
                raise ApiServerException(f"Failed to process upload response: {str(e)}")
        except requests.exceptions.RequestException as e:
            raise ApiServerException(f"Failed to upload logfile: {e}")