def METHOD_NAME(context):
    for cluster in context.clusters:
        context.determine_scribereader_envs_patch.assert_any_call(
            context.scribe_log_reader, context.components, cluster
        )
    # NOTE: Assertions about scribe_tail_patch break under multiprocessing.
    # We think this is because the patched scribe_tail's attributes
    # (call_count, call_args, etc.) don't get updated here in the main
    # thread where we can inspect them. (The patched-in code does run,
    # however, since it prints debugging messages.)
    #
    # Instead, we'll rely on what we can see, which is the result of the
    # thread's work deposited in the shared queue.
    assert context.print_log_patch.call_count == 2
    context.print_log_patch.assert_any_call(
        "fake log line added for env1", context.levels, False, False
    )
    context.print_log_patch.assert_any_call(
        "fake log line added for env2", context.levels, False, False
    )