luigi.server module

Simple REST server that takes commands in a JSON payload Interface to the Scheduler class. See Using the Central Scheduler for more info.

class luigi.server.cors(*args, **kwargs)

Bases: Config

enabled = BoolParameter (defaults to False): Enables CORS support.

allow_any_origin = BoolParameter (defaults to False): Accepts requests from any origin.

allow_null_origin = BoolParameter (defaults to False): Allows the request to set `null` value of the `Origin` header.

max_age = IntParameter (defaults to 86400): Content of `Access-Control-Max-Age`.

allowed_methods = Parameter (defaults to GET, OPTIONS): Content of `Access-Control-Allow-Methods`.

allowed_headers = Parameter (defaults to Accept, Content-Type, Origin): Content of `Access-Control-Allow-Headers`.

exposed_headers = Parameter (defaults to ): Content of `Access-Control-Expose-Headers`.

allow_credentials = BoolParameter (defaults to False): Indicates that the actual request can include user credentials.

allowed_origins = ListParameter (defaults to []): A list of allowed origins. Used only if `allow_any_origin` is false.

class luigi.server.RPCHandler(*args, **kwargs)

Bases: RequestHandler

Handle remote scheduling calls using rpc.RemoteSchedulerResponder.

initialize(scheduler)

options(*args)

get(method)

post(method)

class luigi.server.BaseTaskHistoryHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: RequestHandler

initialize(scheduler)

get_template_path()

Override to customize template path for each handler.

By default, we use the template_path application setting. Return None to load templates relative to the calling file.

class luigi.server.AllRunHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get()

class luigi.server.SelectedRunHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get(name)

luigi.server.from_utc(utcTime, fmt=None)

convert UTC time string to time.struct_time: change datetime.datetime to time, return time.struct_time type

class luigi.server.RecentRunHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get()

class luigi.server.ByNameHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get(name)

class luigi.server.ByIdHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get(id)

class luigi.server.ByParamsHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get(name)

class luigi.server.RootPathHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: BaseTaskHistoryHandler

get()

head()

HEAD endpoint for health checking the scheduler

class luigi.server.MetricsHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)

Bases: RequestHandler

initialize(scheduler)

get()

luigi.server.app(scheduler)

luigi.server.run(api_port=8082, address=None, unix_socket=None, scheduler=None)

Runs one instance of the API server.

luigi.server.stop()