Commit 743f8b89 authored by Yakubov, Sergey's avatar Yakubov, Sergey
Browse files

Merge branch 'fix_status_message' into 'dev'

pulsat logs, fix status message

See merge request !137
parents 80ab33dc 4d6df0c6
Loading
Loading
Loading
Loading
Loading
+3 −2
Original line number Diff line number Diff line
@@ -188,19 +188,20 @@ username = {self.config['username']}
            auth_host=self.config["auth_host"],
            account=self.config["account"],
            auth_type=self.config["auth_type"],
            logger=log,
            creds={"username": self.config["username"], "password": self.config["password"]},
        )
        return client

    def get_rucio_upload_client(self, auth_token=None):
        client = self.get_rucio_client()
        uc = UploadClient(_client=client)
        uc = UploadClient(_client=client,logger=log)
        uc.auth_token = auth_token
        return uc

    def get_rucio_download_client(self, auth_token=None):
        client = self.get_rucio_client()
        dc = DownloadClient(client=client)
        dc = DownloadClient(client=client,logger=log)
        dc.auth_token = auth_token
        return dc

+2 −2
Original line number Diff line number Diff line
@@ -6,7 +6,7 @@ from typing import (
    Optional,
    Tuple,
    TYPE_CHECKING,
    Union,
    Union, Any,
)

from typing_extensions import (
@@ -59,7 +59,7 @@ class MaxDiscoveredFilesJobMessage(JobMessage):
    type: Literal["max_discovered_files"]


AnyJobMessage = Union[ExitCodeJobMessage, RegexJobMessage, MaxDiscoveredFilesJobMessage]
AnyJobMessage = Union[ExitCodeJobMessage, RegexJobMessage, MaxDiscoveredFilesJobMessage, Any]


def check_output_regex(