Skip to content

Instantly share code, notes, and snippets.

View joachimdb's full-sized avatar

Joachim De Beule joachimdb

  • Clarabridge
  • Ghent, Belgium
View GitHub Profile
from gensim.corpora import WikiCorpus
from gensim.models import Phrases
from gensim.models.phrases import Phraser
from gensim.models import Word2Vec
from gensim.models.callbacks import CallbackAny2Vec
import time
wiki_corpus = WikiCorpus("/data/enwiki-latest-pages-articles-multistream.xml.bz2", dictionary={})
phrases = Phrases(wiki_corpus.get_texts(), scoring='npmi', threshold=0.5, min_count=5)
phraser = Phraser(phrases)
defmodule MarketState.Filter.ActivationPrice do
use GenStage
alias __MODULE__
@moduledoc """
GenServer/Genstage that consumes `market_state` events and produces `{:breach, market, price}` events
- Call `monitor(market, breach_price)` to produce events when the price of `market` breaches `breach_price`
defmodule ActivationPolicy.RunningStop do
alias __MODULE__
alias ActivationPolicy.Util
@moduledoc """
Running stop policy
Parameters:
defmodule ActivationPolicy do
alias __MODULE__
@moduledoc """
Provides a generic structure for representing activation policies and their state, as well as an
interface for updating and querying state.
See submodules for specific implementations
@joachimdb
joachimdb / gist:72ca1b7c4630d5a20d25cc3d82c4c563
Created September 4, 2019 20:56
testing async_nolink task messages and shutdown
defmodule Cryptod.Executor.TestTask do
use GenServer
require Logger
def start_link(state \\ %{}) do
GenServer.start_link(__MODULE__, state, name: :test_task)
end
def run_task(id, timeout) do
GenServer.call(:test_task, {:fire, id, timeout})

Keybase proof

I hereby claim:

  • I am joachimdb on github.
  • I am jdbmeta (https://keybase.io/jdbmeta) on keybase.
  • I have a public key ASAc-o8ioKtuNK49tz4F38kebtvqIts-IChZ3o2Uy1UzPQo

To claim this, I am signing this object: