SemanticBeeng

Discussions about marshalling streams in `Akka` and `Alpakka` * https://github.com/akka/akka/issues/21826 * https://github.com/akka/alpakka/issues/63 * https://github.com/Tradeshift/ts-reaktive/tree/master/ts-reaktive-marshal The above idea is more generic because it proposes marshalling the `Source` as opposed all the...

`gRPC` has some design elements that could be adopted in `autowire`, I think. It uses `stream` key word on *.proto files to define streaming APIs * https://grpc.io/docs/tutorials/basic/java.html#example-code-and-setup * https://github.com/grpc/grpc-java/blob/master/examples/src/main/proto/route_guide.proto#L52 It...

Maybe we can reuse the approach from `frameless` https://github.com/typelevel/frameless > _Frameless intentionally does not have a compile dependency on Spark. This essentially allows you to use any version of Frameless...

Trying to think if there is something to reuse from `frameless` :thinking: https://typelevel.org/frameless/TypedEncoder.html https://github.com/typelevel/frameless/tree/master/dataset/src/test/scala/frameless

Called under finally; see second `println` My guess is that jep get finally-ized after thread terminated and its use of `isValidThread` causes the crash: `threadstate_getframe+0x0.` Does something like that make...

Yes, same thread. First run in sbt ``` > test-only com.knowscieng.datalayer.AnalysisOrchestrationSpec spec start run jep.Jep@65da5011 on thread specs2-3 >>>>>>> Extracted feature 100 1 spec end end jep.Jep@65da5011 on thread specs2-3...

Alternative experiment to troubleshoot using insights from https://github.com/ninia/jep/issues/28#issuecomment-150028479 If I use a python script like this ``` import numpy def init(something): numpy.ndarray([1]).any() return 1 ``` then same thing happens in...

Did some research into potentially related issues https://github.com/ninia/jep/issues/28 > _"ep3.4.1 on Mac in a Scala environment, with scipy. If I try to initialize multiple jep instances and import scipy, I...

Introduced use of shared modules and this has improved stability (see https://groups.google.com/forum/#!topic/jep-project/KkDgwpIUayQ by Ben) ``` val config = new JepConfig().addSharedModules("numpy","rpy2") def foreach[R: AsResult](f: Jep => R): Result = { println("Initializing...

_" managed to crash without using much python "_ - I believe it was from `import pandas2ri` At some point I managed to avoid crash by simply commenting that out....