Луиджи не использует хост / порт планировщика из конфигурации - PullRequest
Новая
       56

Луиджи не использует хост / порт планировщика из конфигурации

0 голосов
/ 08 мая 2020

Пожалуйста, дайте мне знать, если я не понимаю Луиджи.

Сейчас у меня luigi работает на экземпляре Linux, который я хочу использовать в качестве центрального планировщика.

При попытке запустить код Python из другого экземпляра, я не могу заставить Python указывать на центральный планировщик. Луиджи всегда пытается подключиться к http://localhost: 8082 . 

luigi.rpc.RPCError: Errors (3 attempts) when connecting to remote scheduler 'http://localhost:8082'

У меня есть файл luigi.cfg в папке проекта, который содержит: 

[core]
default_scheduler_host=some-ip
default_scheduler_port=some-port
default_scheduler_url=http://some-ip:some-port

Я также установил в этот файл переменную LUIGI_CONFIG_PATH.

Тем не менее, Python пытается подключиться к http://localhost: 8082 . Что я здесь делаю не так?

1 Ответ

0 голосов
/ 08 мая 2020

В итоге я просмотрел код luigi в своем пакете сайта и нашел следующий код: 

scheduler_host = parameter.Parameter(
    default='localhost',
    description='Hostname of machine running remote scheduler',
    config_path=dict(section='core', name='default-scheduler-host'))
scheduler_port = parameter.IntParameter(
    default=8082,
    description='Port of remote scheduler api process',
    config_path=dict(section='core', name='default-scheduler-port'))
scheduler_url = parameter.Parameter(
    default='',
    description='Full path to remote scheduler',
    config_path=dict(section='core', name='default-scheduler-url'),
)

Оказывается, версия luigi, которую я использовал, ищет default-scheduler-host вместо default_scheduler_port , et c.

...