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:
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 |
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}) |
I hereby claim:
To claim this, I am signing this object: