Julien Lhermitte

Feature Request: df.sort_values()

3

# Description Requesting the feature `df.sort_values()` . I have checked and do not see any other issues about this one. Happy to contribute if you point me in the right...

Should streamz handle exceptions?

7

What do we do when a stream receives bad data that causes an exception to be raised. For ex: ```python def foo(x): if x is None: raise Exception else: return...

long tracebacks

1

I'm wondering if we can avoid long tracebacks: ```py3 In [1]: from streamz import Stream In [2]: s = Stream() In [3]: snext = s ...: for i in range(10):...

Documentation about weakrefs

2

We should eventually make sure this gets into the documentation (in reaction to #72) Something like: ```python s = Stream() s2 = s.map(lambda x : x + 1) s2.map(print) s.emit(1)...

Strange AttributeError

1

I'm running a fairly complicated pipeline but it works surprisingly well. ( [this dag](https://github.com/CFN-softbio/SciStreams/blob/lightflow-dag-extension/SciStreams/workflows/main.py) calls [this dag](https://github.com/CFN-softbio/SciStreams/blob/lightflow-dag-extension/SciStreams/workflows/primary.py) which calls [this dag](https://github.com/CFN-softbio/SciStreams/blob/lightflow-dag-extension/SciStreams/workflows/one_image.py) ) However, sometimes, I encounter this error below on...

Hi, I have a DAG that generates many other DAG's. I would like it to generate at most `N` running DAG's. Is there a way to check within a `PythonTask`...

Right now, we explain the version sentinel but we don't show a way to test. http://nsls-ii.github.io/databroker/creating.html we should add something. i suggest to add inserting and checking a resource

Add a suggestion for using tailscale for code-server. This alternative is useful for those that want more options for connecting their IPads to their code server. I'm not sure if...