Module test_collections

distributed.tests.test_collections

Functions

▷ def assert_equal(a, b)
source link
▷ def make_time_dataframe()
source link
▷ def test_dataframe_groupby_tasks(client)
source link
▷ def test_dataframe_set_index_sync(wait, client) @pytest.mark.parametrize("wait", [wait, lambda x: None])
@pytest.mark.parametrize("wait", [wait, lambda x: None])
def test_dataframe_set_index_sync(
wait,
client,
)
source link
▷ def test_loc_sync(client)
source link
▷ def test_rolling_sync(client)
source link
▷ def test_tuple_futures_arg(client, typ) @pytest.mark.parametrize("typ", [tuple, list])
@pytest.mark.parametrize("typ", [tuple, list])
def test_tuple_futures_arg(
client,
typ,
)
source link