import os
import numpy as np
import pandas as pd
import cudf
import dask_cudf
from dask.distributed import Client

np.random.seed(12)
df = cudf.DataFrame([('a', list(range(20))),
    ('b', list(reversed(range(20)))),
    ('c', list(range(20)))])
print(df)

ddf = dask_cudf.from_cudf(df, npartitions=2) 
print(ddf.persist())

client = Client("127.0.0.1:8487")
client.publish_dataset(shared_dataset1=ddf)
print(client.list_datasets())


8db94c45013f64190cb81f0918d5ba47c9c20a48
<mask token>

<mask token>
np.random.seed(12)
<mask token>
print(df)
<mask token>
print(ddf.persist())
<mask token>
client.publish_dataset(shared_dataset1=ddf)
print(client.list_datasets())

<mask token>
np.random.seed(12)
df = cudf.DataFrame([('a', list(range(20))), ('b', list(reversed(range(20))
    )), ('c', list(range(20)))])
print(df)
ddf = dask_cudf.from_cudf(df, npartitions=2)
print(ddf.persist())
client = Client('127.0.0.1:8487')
client.publish_dataset(shared_dataset1=ddf)
print(client.list_datasets())

import os
import numpy as np
import pandas as pd
import cudf
import dask_cudf
from dask.distributed import Client
np.random.seed(12)
df = cudf.DataFrame([('a', list(range(20))), ('b', list(reversed(range(20))
    )), ('c', list(range(20)))])
print(df)
ddf = dask_cudf.from_cudf(df, npartitions=2)
print(ddf.persist())
client = Client('127.0.0.1:8487')
client.publish_dataset(shared_dataset1=ddf)
print(client.list_datasets())

import os
import numpy as np
import pandas as pd
import cudf
import dask_cudf
from dask.distributed import Client

np.random.seed(12)
df = cudf.DataFrame([('a', list(range(20))),
    ('b', list(reversed(range(20)))),
    ('c', list(range(20)))])
print(df)

ddf = dask_cudf.from_cudf(df, npartitions=2) 
print(ddf.persist())

client = Client("127.0.0.1:8487")
client.publish_dataset(shared_dataset1=ddf)
print(client.list_datasets())

