Commit 4d6df0c6 authored by Yakubov, Sergey's avatar Yakubov, Sergey
Browse files

pulsat logs, fix status message

parent 565baaba

.gitlab-ci.yml

+2 −2
Original line number Diff line number Diff line
@@ -9,8 +9,8 @@ variables: 
  CONTAINER_GALAXY_URL: "${NDIP_DOCKER_REPOSITORY}/${CI_PROJECT_PATH}"

  CONTAINER_GALAXY_BASE_URL: "${CONTAINER_GALAXY_URL}/base"

  CONTAINER_GALAXY_COMMIT_URL: "${CONTAINER_GALAXY_URL}/commit"

  GALAXY_VERSION_PYTHON: 25.1.dev0+ornl

  GALAXY_VERSION_DOCKER: 25.1.dev0.ornl

  GALAXY_VERSION_PYTHON: 25.1.dev1+ornl

  GALAXY_VERSION_DOCKER: 25.1.dev1.ornl



# This import is for the func_rse_docker_* functions

before_script:

lib/galaxy/objectstore/rucio.py

+3 −2
Original line number Diff line number Diff line
@@ -184,19 +184,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

lib/galaxy/tool_util/output_checker.py

+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(