Module Import alias Import alias Import alias Import alias Import alias Import alias Import alias ImportFrom alias alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias alias alias identifier Import alias ImportFrom alias ImportFrom alias TryExcept body ImportFrom alias handlers ExceptHandler type NameLoad body Import alias FunctionDef arguments args defaults body Expr Str Return Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr FunctionDef arguments args NameParam NameParam NameParam defaults vararg kwarg body If Call NameLoad body Assign NameStore Call AttributeLoad Call NameLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword Str If CompareGtE AttributeLoad NameLoad attr Num body Raise Call AttributeLoad AttributeLoad NameLoad attr attr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list Assign AttributeStore AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Assign AttributeStore AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign NameStore AttributeLoad Call AttributeLoad NameLoad attr Str attr Expr Call AttributeLoad NameLoad attr CompareNotEq Call AttributeLoad NameLoad attr Str Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str Assign NameStore Str FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr keyword AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Num Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore AttributeLoad NameLoad attr attr Lambda arguments args defaults NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword Num If Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr keyword Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr Str Str NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str decorator_list Call NameLoad Str FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Dict Str Str decorator_list Call NameLoad Str FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Dict Str Str Str Str decorator_list Call NameLoad Str FunctionDef arguments args NameParam defaults body With Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Dict Str Num decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str keyword TupleLoad Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Expr Call AttributeLoad NameLoad attr SubscriptLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Index Str Str Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad SubscriptLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Index Str Index Num Expr Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Str decorator_list Call NameLoad Str decorator_list ClassDef bases NameLoad body ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad Call NameLoad keyword Str keyword Call NameLoad AttributeLoad NameLoad attr keyword Str keyword Str keyword Str keyword Str keyword Str attr Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list Assign NameStore NameLoad FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list Call NameLoad Str ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd Str Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore ListLoad Str Str Call NameLoad AttributeLoad AttributeLoad NameLoad attr attr Str Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword Str decorator_list decorator_list Assign NameStore NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults vararg kwarg body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad decorator_list Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str NameLoad FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr With Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str NameLoad body Assign NameStore AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list Call NameLoad Str decorator_list ClassDef bases NameLoad body ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Str Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list Assign NameStore NameLoad decorator_list ClassDef bases NameLoad body ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Str Call NameLoad AttributeLoad NameLoad attr Str Str AttributeLoad NameLoad attr Str Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str decorator_list Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list Assign NameStore NameLoad decorator_list
N/A N/A functools N/A os N/A multiprocessing N/A shutil N/A signal N/A time N/A tempfile helpers unittest skipOnTravis N/A luigi.rpc N/A luigi.server N/A luigi.cmdline luigi.scheduler CentralPlannerScheduler luigi.six.moves.urllib.parse urlencode ParseResult quote urlquote N/A tornado.ioloop tornado.testing AsyncHTTPTestCase nose.plugins.attrib attr N/A N/A unittest mock N/A N/A N/A ImportError N/A N/A mock _is_running_from_main_thread N/A N/A N/A N/A N/A 
    Return true if we're the same thread as the one that created the Tornado
    IOLoop. In practice, the problem is that we get annoying intermittent
    failures because sometimes the KeepAliveThread jumps in and "disturbs" the
    intended flow of the test case. Worse, it fails in the terrible way that
    the KeepAliveThread is kept alive, bugging the execution of subsequent test
    casses.

    Oh, I so wish Tornado would explicitly say that you're acessing it from
    different threads and things will just not work.
     N/A N/A N/A N/A N/A tornado ioloop IOLoop current instance False N/A ServerTestBase N/A AsyncHTTPTestCase N/A get_app N/A N/A self N/A N/A N/A N/A N/A N/A luigi server app N/A CentralPlannerScheduler N/A setUp N/A N/A self N/A N/A N/A N/A N/A N/A super ServerTestBase self setUp N/A N/A self _old_fetch N/A N/A N/A luigi rpc RemoteScheduler _fetch _fetch N/A N/A obj url body N/A args kwargs N/A N/A N/A _is_running_from_main_thread N/A N/A body N/A N/A N/A urlencode body encode utf-8 N/A response N/A N/A self fetch url body body method POST N/A N/A N/A response code 400 N/A N/A N/A N/A N/A luigi rpc RPCError Errror when connecting to remote scheduler N/A N/A N/A N/A response body decode utf-8 N/A N/A N/A N/A N/A luigi rpc RemoteScheduler _fetch _fetch N/A tearDown N/A N/A self N/A N/A N/A N/A N/A N/A super ServerTestBase self tearDown N/A N/A N/A N/A luigi rpc RemoteScheduler _fetch N/A self _old_fetch N/A N/A ServerTest N/A ServerTestBase N/A test_visualiser N/A N/A self N/A N/A N/A page N/A N/A N/A self fetch / body N/A N/A N/A self assertTrue N/A N/A N/A page find <title> -1 N/A _test_404 N/A N/A self path N/A N/A N/A response N/A N/A self fetch path N/A N/A N/A self assertEqual N/A response code 404 N/A test_404 N/A N/A self N/A N/A N/A N/A N/A self _test_404 /foo N/A test_api_404 N/A N/A self N/A N/A N/A N/A N/A self _test_404 /api/foo N/A N/A _ServerTest N/A N/A unittest TestCase N/A N/A 
    Test to start and stop the server in a more "standard" way
     N/A server_client_class To be defined by subclasses start_server N/A N/A self N/A N/A N/A N/A self _process N/A N/A multiprocessing Process target N/A N/A self server_client run_server N/A N/A N/A N/A self _process start N/A N/A N/A time sleep 0.1 N/A N/A self sch N/A N/A N/A self server_client scheduler N/A N/A N/A self sch _wait N/A N/A N/A N/A None N/A stop_server N/A N/A self N/A N/A N/A N/A N/A N/A self _process terminate N/A N/A N/A N/A self _process join timeout 1 N/A N/A N/A N/A self _process is_alive N/A N/A N/A N/A os kill N/A N/A self _process pid N/A signal SIGKILL N/A setUp N/A N/A self N/A N/A N/A N/A self server_client N/A N/A self server_client_class N/A state_path N/A N/A tempfile mktemp suffix N/A N/A self id N/A N/A N/A self addCleanup N/A N/A functools partial N/A os unlink state_path N/A N/A N/A N/A N/A N/A luigi configuration get_config set scheduler state_path state_path N/A N/A N/A self start_server N/A tearDown N/A N/A self N/A N/A N/A N/A N/A self stop_server N/A test_ping N/A N/A self N/A N/A N/A N/A N/A N/A self sch ping worker xyz N/A N/A skipOnTravis https://travis-ci.org/spotify/luigi/jobs/78315794 test_raw_ping N/A N/A self N/A N/A N/A N/A N/A N/A self sch _request /api/ping N/A worker xyz N/A N/A skipOnTravis https://travis-ci.org/spotify/luigi/jobs/78023665 test_raw_ping_extended N/A N/A self N/A N/A N/A N/A N/A N/A self sch _request /api/ping N/A worker foo xyz bar N/A N/A skipOnTravis https://travis-ci.org/spotify/luigi/jobs/78023665 test_404 N/A N/A self N/A N/A N/A N/A N/A self assertRaises N/A N/A luigi rpc RPCError N/A N/A N/A N/A N/A self sch _request /api/fdsfds N/A dummy 1 N/A test_save_state N/A N/A self N/A N/A N/A N/A N/A N/A self sch add_task X B deps N/A A N/A N/A N/A N/A self sch add_task X A N/A N/A N/A self assertEqual N/A N/A N/A N/A self sch get_work X N/A task_id A N/A N/A N/A self stop_server N/A N/A N/A self start_server N/A work N/A N/A N/A N/A N/A self sch get_work X N/A running_tasks N/A 0 N/A N/A N/A self assertEqual N/A work N/A task_id A N/A N/A skipOnTravis https://travis-ci.org/spotify/luigi/jobs/72953884 N/A UNIXServerTest N/A _ServerTest N/A ServerClient N/A object N/A __init__ N/A N/A self N/A N/A N/A N/A self tempdir N/A N/A tempfile mkdtemp N/A N/A self unix_socket N/A N/A N/A os path join N/A self tempdir luigid.sock N/A run_server N/A N/A self N/A N/A N/A N/A N/A N/A luigi server run unix_socket N/A self unix_socket N/A scheduler N/A N/A self N/A N/A N/A url N/A N/A N/A ParseResult scheme http+unix netloc N/A urlquote N/A self unix_socket safe path params query fragment geturl N/A N/A N/A N/A luigi rpc RemoteScheduler url N/A N/A N/A server_client_class ServerClient tearDown N/A N/A self N/A N/A N/A N/A N/A N/A super UNIXServerTest self tearDown N/A N/A N/A shutil rmtree N/A N/A self server_client tempdir N/A N/A N/A attr unixsocket INETServerClient N/A object N/A __init__ N/A N/A self N/A N/A N/A N/A self port 8083 N/A scheduler N/A N/A self N/A N/A N/A N/A N/A N/A luigi rpc RemoteScheduler N/A http://localhost: N/A str N/A self port N/A N/A _INETServerTest N/A _ServerTest N/A test_with_cmdline N/A N/A self N/A N/A N/A 
        Test to run against the server as a normal luigi invocation does
         N/A params N/A Task --scheduler-port N/A str N/A N/A self server_client port --no-lock N/A N/A N/A self assertTrue N/A N/A N/A luigi interface run params N/A N/A INETProcessServerTest N/A _INETServerTest N/A ServerClient N/A INETServerClient N/A run_server N/A N/A self N/A N/A N/A N/A N/A N/A luigi server run api_port N/A self port address 127.0.0.1 N/A N/A N/A server_client_class ServerClient N/A INETURLLibServerTest N/A INETProcessServerTest N/A start_server N/A N/A self N/A args kwargs N/A N/A N/A N/A N/A super INETURLLibServerTest self start_server args kwargs N/A N/A N/A N/A mock patch object N/A luigi rpc HAS_REQUESTS False patching_test N/A N/A self N/A N/A N/A 
        Check that HAS_REQUESTS patching is meaningful
         N/A fetcher1 N/A N/A N/A N/A luigi rpc RemoteScheduler _fetcher N/A N/A N/A N/A mock patch object N/A luigi rpc HAS_REQUESTS False N/A N/A fetcher2 N/A N/A N/A N/A luigi rpc RemoteScheduler _fetcher N/A N/A N/A self assertNotEqual N/A fetcher1 __class__ N/A fetcher2 __class__ N/A N/A skipOnTravis https://travis-ci.org/spotify/luigi/jobs/81022689 N/A INETLuigidServerTest N/A _INETServerTest N/A ServerClient N/A INETServerClient N/A run_server N/A N/A self N/A N/A N/A N/A N/A N/A luigi cmdline luigid N/A --port N/A str N/A self port N/A N/A N/A server_client_class ServerClient N/A INETLuigidDaemonServerTest N/A _INETServerTest N/A ServerClient N/A INETServerClient N/A __init__ N/A N/A self N/A N/A N/A N/A N/A N/A super N/A INETLuigidDaemonServerTest ServerClient self __init__ N/A N/A self tempdir N/A N/A tempfile mkdtemp N/A run_server N/A N/A self daemon_context N/A N/A N/A N/A N/A N/A luigi cmdline luigid N/A --port N/A str N/A self port --background --logdir N/A self tempdir --pidfile N/A N/A N/A os path join N/A self tempdir luigid.pid N/A N/A N/A mock patch daemon.DaemonContext N/A tearDown N/A N/A self N/A N/A N/A N/A N/A N/A super INETLuigidDaemonServerTest self tearDown N/A N/A N/A shutil rmtree N/A N/A self server_client tempdir N/A N/A server_client_class ServerClient N/A