Commit e171529f authored by Felix Delattre's avatar Felix Delattre
Browse files

Updated to latest rabotnik variable handling

parent ab6b094d
Pipeline #41950 passed with stage
in 2 minutes and 5 seconds
image: python:3-buster
image: python:3.9-buster
variables:
RABOTNIK_CELERY_BROKER_HOST: "unset"
RABOTNIK_CELERY_BROKER_USER: "unset"
RABOTNIK_CELERY_BROKER_PASSWORD: "unset"
RABOTNIK_MESSAGE_BUS_HOST: "unset"
RABOTNIK_MESSAGE_BUS_USER: "unset"
RABOTNIK_MESSAGE_BUS_PASSWORD: "unset"
RABOTNIK_STORAGES: "unset"
before_script:
- python3 -V
......
......@@ -10,7 +10,7 @@ repos:
- id: trailing-whitespace
- repo: https://github.com/psf/black
rev: 20.8b1
rev: 22.3.0
hooks:
- id: black
args: [ --line-length=96 ]
......
......@@ -20,8 +20,9 @@ import argparse
import sys
import asyncio
import logging
import os
from rabotnik.bus import MessageBus
from rabotnik import MessageBus
from .argument_factory import ArgumentFactory
......@@ -120,13 +121,14 @@ def main(args: list = None, message_bus: MessageBus = None):
logging.getLogger("rabotnik").setLevel(logging.DEBUG)
logger.setLevel(logging.DEBUG)
os.environ.setdefault("RABOTNIK_MESSAGE_BUS_HOST", args.hostname)
os.environ.setdefault("RABOTNIK_MESSAGE_BUS_USER", args.username)
os.environ.setdefault("RABOTNIK_MESSAGE_BUS_PASSWORD", args.password)
if message_bus is None:
message_bus = MessageBus()
loop.create_task(
message_bus.connect(
host=args.hostname,
username=args.username,
password=args.password,
timeout=args.timeout,
)
)
......
......@@ -35,7 +35,9 @@ setup(
author="Helmholtz-Zentrum Potsdam Deutsches GeoForschungsZentrum GFZ",
url="https://git.gfz-potsdam.de/dynamicexposure/rabotnik/rcom",
license="AGPLv3+",
install_requires=["rabotnik==0.0.3"],
install_requires=[
"rabotnik@git+https://git.gfz-potsdam.de/dynamicexposure/rabotnik/rabotnik.git", # noqa: E501
],
tests_require=tests_require,
extras_require={
"tests": tests_require,
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment