Module Import alias Import alias Import alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad Str attr GeneratorExp Call AttributeLoad NameLoad attr BinOpAdd AttributeLoad NameLoad attr AttributeLoad NameLoad attr comprehension NameStore Call NameLoad NameLoad decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str Assign NameStore ListLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad decorator_list decorator_list FunctionDef arguments args NameParam defaults body Expr Str Pass decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str Assign NameStore Str FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr ListLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad NameLoad Index Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore BoolOpOr NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad NameLoad attr Num Call NameLoad NameLoad Assign NameStore SubscriptLoad NameLoad Index Num Expr Call AttributeLoad NameLoad attr BinOpAdd Str NameLoad SubscriptLoad NameLoad Index Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Dict Str Str Str Str Str NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Num AttributeLoad NameLoad attr Return SubscriptLoad NameLoad Index Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr Assign NameStore Num Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str keyword AttributeLoad NameLoad attr keyword Num Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad Str Expr Call AttributeLoad NameLoad attr CompareLtE BinOpAdd NameLoad Num NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore BinOpAdd Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr keyword Num Assign NameStore Num Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str keyword AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign SubscriptStore AttributeLoad NameLoad attr Index Str AttributeLoad NameLoad attr TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str finalbody Delete SubscriptDel AttributeLoad NameLoad attr Index Str Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str keyword Str keyword BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Assign TupleStore NameStore NameStore SubscriptLoad AttributeLoad NameLoad attr Index Num Expr Call AttributeLoad NameLoad attr BinOpAdd Str NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str keyword Str keyword BinOpAdd BinOpAdd AttributeLoad NameLoad attr Str AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign NameStore Str Assign NameStore Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr Call NameLoad Num NameLoad keyword Dict Str Str keyword Str keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign NameStore Str FunctionDef arguments args defaults body Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr NameLoad keyword Dict Str Str keyword Str keyword AttributeLoad NameLoad attr keyword NameLoad decorator_list Call AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad attr Assign NameStore Num Assign NameStore Str FunctionDef arguments args defaults body Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr Str BinOpAdd NameLoad Str Str Dict Str Str BinOpAdd BinOpAdd NameLoad Str AttributeLoad NameLoad attr Call NameLoad Num NameLoad keyword Dict Str Str keyword Str keyword AttributeLoad NameLoad attr keyword NameLoad decorator_list Call AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list If CompareEq NameLoad Str body Expr Call AttributeLoad NameLoad attr
N/A N/A datetime N/A os N/A random N/A string N/A time N/A unittest google.appengine.ext db mapreduce control mapreduce hooks mapreduce model mapreduce test_support testlib testutil mapreduce.api map_job random_string N/A N/A length N/A N/A N/A Generate a random string of given length. N/A N/A N/A join N/A N/A N/A random choice N/A N/A string letters N/A string digits N/A _ N/A range length N/A TestEntity N/A N/A db Model N/A N/A Test entity class. N/A TestHooks N/A N/A hooks Hooks N/A N/A Test hooks class. N/A enqueue_kickoff_task_calls N/A enqueue_kickoff_task N/A N/A self task queue_name N/A N/A N/A N/A N/A N/A TestHooks enqueue_kickoff_task_calls append N/A task queue_name N/A N/A test_handler N/A N/A entity N/A N/A N/A Test handler function. N/A N/A ControlTest N/A N/A testutil HandlerTestBase N/A N/A Tests for control module. N/A QUEUE_NAME crazy-queue setUp N/A N/A self N/A N/A N/A N/A N/A N/A testutil HandlerTestBase setUp self N/A N/A TestHooks enqueue_kickoff_task_calls N/A N/A get_mapreduce_spec N/A N/A self task N/A N/A N/A Get mapreduce spec form kickoff task payload. N/A payload N/A N/A test_support decode_task_payload task N/A N/A N/A N/A model MapreduceSpec from_json_str N/A payload N/A mapreduce_spec N/A validate_map_started N/A N/A self mapreduce_id queue_name N/A None N/A N/A Tests that the map has been started. N/A queue_name N/A queue_name N/A self QUEUE_NAME N/A N/A N/A self assertTrue mapreduce_id N/A tasks N/A N/A N/A self taskqueue GetTasks queue_name N/A N/A N/A self assertEquals 1 N/A len tasks N/A task N/A tasks N/A 0 N/A N/A N/A self assertEqual N/A /mapreduce_base_path/kickoffjob_callback/ mapreduce_id N/A task N/A url N/A handler N/A N/A test_support execute_task task N/A N/A N/A self assertEqual mapreduce_id N/A N/A N/A handler request get mapreduce_id N/A state N/A N/A N/A model MapreduceState get_by_job_id mapreduce_id N/A params N/A N/A N/A map_job JobConfig _get_default_mr_params N/A N/A N/A params update N/A foo base_path queue_name bar /mapreduce_base_path queue_name N/A N/A N/A self assertEqual N/A N/A state mapreduce_spec params params N/A job_config N/A N/A N/A map_job JobConfig _to_map_job_config N/A state mapreduce_spec queue_name N/A N/A N/A self assertEqual 0 N/A job_config _api_version N/A N/A task N/A eta N/A testStartMap N/A N/A self N/A N/A N/A Test start_map function.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name N/A self QUEUE_NAME N/A N/A N/A self validate_map_started mapreduce_id N/A testStartMap_Countdown N/A N/A self N/A N/A N/A Test that MR can be scheduled into the future.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A now_sec N/A long N/A N/A time time N/A shard_count 4 N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name N/A self QUEUE_NAME countdown 1000 N/A task_eta N/A N/A self validate_map_started mapreduce_id N/A eta_sec N/A N/A time mktime N/A N/A time strptime task_eta %Y/%m/%d %H:%M:%S N/A N/A N/A self assertTrue N/A N/A now_sec 1000 eta_sec N/A testStartMap_Eta N/A N/A self N/A N/A N/A Test that MR can be scheduled into the future.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A eta N/A N/A N/A N/A datetime datetime utcnow N/A N/A datetime timedelta hours 1 N/A shard_count 4 N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name N/A self QUEUE_NAME eta eta N/A task_eta N/A N/A self validate_map_started mapreduce_id N/A N/A N/A self assertEquals N/A N/A eta strftime %Y/%m/%d %H:%M:%S task_eta N/A testStartMap_QueueEnvironment N/A N/A self N/A N/A N/A Test that the start_map inherits its queue from the enviornment. N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A N/A N/A os environ N/A HTTP_X_APPENGINE_QUEUENAME N/A self QUEUE_NAME N/A N/A N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path N/A N/A N/A N/A os environ N/A HTTP_X_APPENGINE_QUEUENAME N/A N/A N/A self validate_map_started mapreduce_id N/A testStartMap_Hooks N/A N/A self N/A N/A N/A Tests that MR can be scheduled with a hook class installed.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name crazy-queue hooks_class_name N/A N/A __name__ . N/A TestHooks __name__ N/A N/A N/A self assertTrue mapreduce_id N/A N/A task queue_name N/A N/A TestHooks enqueue_kickoff_task_calls N/A 0 N/A N/A N/A self assertEqual N/A /mapreduce_base_path/kickoffjob_callback/ mapreduce_id N/A task url N/A N/A N/A self assertEqual crazy-queue queue_name N/A testStartMap_RaisingHooks N/A N/A self N/A N/A N/A Tests that MR can be scheduled with a dummy hook class installed.

    The dummy hook class raises NotImplementedError for all method calls so the
    default scheduling logic should be used.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name crazy-queue hooks_class_name N/A N/A N/A hooks __name__ . N/A N/A hooks Hooks __name__ N/A N/A N/A self validate_map_started mapreduce_id N/A testStartMap_HugePayload N/A N/A self N/A N/A N/A Test start_map function.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A mapreduce_id N/A mapreduce_id N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind huge_parameter N/A N/A __name__ . N/A TestEntity __name__ N/A random_string 900000 shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name N/A self QUEUE_NAME N/A N/A N/A self validate_map_started mapreduce_id N/A testStartMapTransactional N/A N/A self N/A N/A N/A Test start_map function.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A mapreduce_id tx N/A N/A N/A N/A N/A some_entity N/A TestEntity N/A N/A N/A some_entity put N/A N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind N/A N/A __name__ . N/A TestEntity __name__ shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name N/A self QUEUE_NAME in_xg_transaction True N/A N/A N/A db transactional xg True N/A mapreduce_id N/A tx N/A N/A N/A self validate_map_started mapreduce_id N/A testStartMapTransactional_HugePayload N/A N/A self N/A N/A N/A Test start_map function.

    Most of start_map functionality is already tested by handlers_test.
    Just a smoke test is enough.
     N/A N/A N/A N/A TestEntity put N/A shard_count 4 N/A mapreduce_id tx N/A N/A N/A N/A N/A some_entity N/A TestEntity N/A N/A N/A some_entity put N/A N/A N/A control start_map test_map N/A __name__ .test_handler mapreduce.input_readers.DatastoreInputReader N/A entity_kind huge_parameter N/A N/A __name__ . N/A TestEntity __name__ N/A random_string 900000 shard_count mapreduce_parameters N/A foo bar base_path /mapreduce_base_path queue_name N/A self QUEUE_NAME in_xg_transaction True N/A N/A N/A db transactional xg True N/A mapreduce_id N/A tx N/A N/A N/A self validate_map_started mapreduce_id N/A N/A N/A N/A __name__ __main__ N/A N/A N/A N/A unittest main