jaredgoldman
a5edaa9b5c
Skip zero test and change use Path when creating a config folder in marketstore
2023-02-26 16:41:06 -05:00
jaredgoldman
944c1945fc
Add backpressure setting back as it wasn't altering test behaviour
2023-02-26 16:11:28 -05:00
jaredgoldman
5ccc72111b
Ensure tests are running and working up until asserting pps
2023-02-26 15:59:55 -05:00
jaredgoldman
178fb8b56e
Remove breaking call to load pps from ledger
2023-02-26 13:12:11 -05:00
jaredgoldman
6068724fd4
Minor formatting
2023-02-26 13:12:11 -05:00
jaredgoldman
2131394939
Remove uneeded assert_precision arg
2023-02-26 13:12:11 -05:00
jaredgoldman
1397a75d2c
Add functionality and tests for executing mutliple orders
2023-02-26 13:12:11 -05:00
jaredgoldman
4eb9b68b0e
Refactor to avoid global state while testing
2023-02-26 13:12:11 -05:00
jaredgoldman
6ccdb8cbf8
Ensure to cleanup by passing fixture in paper_test signature
2023-02-26 13:12:11 -05:00
jaredgoldman
4d32c6f6a2
Ensure not to write to pps when asserting?
2023-02-26 13:12:11 -05:00
jaredgoldman
bf1757de07
Push failing assert no pps test
2023-02-26 13:12:11 -05:00
jaredgoldman
c8e6312044
Reformat fake fill in paper engine,
...
Ensure tests pass, refactor test wrapper
2023-02-26 13:12:11 -05:00
jaredgoldman
e8714c2d17
Ensure actual pp is sent to ems
...
ensure not to write pp header on startup
Comment out pytest settings
Add comments explaining delete_testing_dir fixture
use nonlocal instead of global for test state
Add unpacking get_fqsn method
Format test_paper
Add comments explaining sync/async book.send calls
2023-02-26 13:12:11 -05:00
algorandpa
cf0b85aa51
Add back cleanup fixture
2023-02-26 13:12:11 -05:00
algorandpa
43a68ef700
Disable cleanup to see if CI passes
2023-02-26 13:12:11 -05:00
algorandpa
519d459dbe
Scope fixture to session
2023-02-26 13:12:11 -05:00
algorandpa
b035fa963c
Fix type
2023-02-26 13:12:11 -05:00
algorandpa
3acc424c3e
only clean up if _testing file exists
2023-02-26 13:12:11 -05:00
algorandpa
1e473874ad
Remove scoping
2023-02-26 13:12:11 -05:00
algorandpa
edce176ff8
Scope cleanup fixture to module
2023-02-26 13:12:11 -05:00
algorandpa
0527310071
Enable backpressure during data-feed layer startup to avoid overruns
2023-02-26 13:12:11 -05:00
algorandpa
47d48ba3a3
Format to prep for PR
2023-02-26 13:12:11 -05:00
algorandpa
51ce71c969
Add hacky cleanup solution for _testng data
2023-02-26 13:12:11 -05:00
algorandpa
66c568c7bc
Minor reformatting
2023-02-26 13:12:11 -05:00
algorandpa
5b0ed6c274
Break test into steps
2023-02-26 13:12:11 -05:00
algorandpa
2ce811f192
Assert that trades persist in ems after teardown and startup
2023-02-26 13:12:11 -05:00
algorandpa
1651e89a06
initial commit on copy
2023-02-26 13:12:11 -05:00
algorandpa
2580259ebe
minor changes, prepare for rebase of overlays branch
2023-02-26 13:12:11 -05:00
Guillermo Rodriguez
47bf45f30e
Merge pull request #464 from pikers/elasticsearch_integration
...
Elasticsearch integration
2023-02-24 16:38:37 -03:00
Esmeralda Gallardo
b96e2c314a
Minor style changes and removed unnecesary comments
2023-02-24 15:11:15 -03:00
Esmeralda Gallardo
f96d6a04b6
Fixed UnboundLocalError on _ahab. Added test for marketstore's initialization
2023-02-22 13:28:07 -03:00
Guillermo Rodriguez
acc6249d88
Remove unnesesary arguments to some pikerd functions, fix container init error
...
by switching from log reading to quering es health endpoint, fix install on ci
and add more logging.
2023-02-21 20:45:10 -03:00
Tyler Goodlet
0b678c97f4
Pass `loglevel: str` cli value through to service tests
2023-02-21 12:02:26 -05:00
Esmeralda Gallardo
4122c482ba
Added new tests for elasticsearch's and marketstore's initialization and stop
2023-02-21 13:34:29 -03:00
Esmeralda Gallardo
b5cdf14036
Modified elasticsearch file name to 'elastic' to avoid name errors. Applied changes suggested in the pr.
2023-02-21 13:34:29 -03:00
Tyler Goodlet
b3400f0d9c
Add `loglevel: str` fixture, passthrough to `open_test_pikerd()`
2023-02-21 10:54:18 -05:00
Tyler Goodlet
cd3e9b1b2a
Move quest fixtures to test mod, clean out old travis fixture
2023-02-21 10:54:18 -05:00
Tyler Goodlet
69074f4fa5
Bump up service tree spawn timeout a couple secs
2023-01-26 17:59:25 -05:00
Tyler Goodlet
fe4fb37b58
Add service tree tests for data-feeds and the EMS
2023-01-24 15:15:27 -05:00
Tyler Goodlet
7cfd431a2b
Yield `Services` in `open_test_pikerd()` fixture
2023-01-24 15:15:27 -05:00
Tyler Goodlet
37e0ec7b7d
Assert fixture caller is `pikerd`
2023-01-13 13:21:49 -05:00
Tyler Goodlet
6a1bb13feb
Add base `pikerd` service tree custom check test
2023-01-13 13:21:49 -05:00
Tyler Goodlet
593db0ed0d
Only run `kraken` feed tests in CI, use `open_test_pikerd()`
2023-01-10 11:09:19 -05:00
Tyler Goodlet
06622105cd
Add a `open_test_pikerd()` acm fixture for easy booting of the service stack
2023-01-10 11:09:19 -05:00
Tyler Goodlet
f232d6d4ee
Add `ci_env` detector fixture
2023-01-10 11:09:19 -05:00
Tyler Goodlet
b7e1443618
Use ETH on kraken to ensure enough quotes
2023-01-10 11:09:19 -05:00
Tyler Goodlet
5d021ffb85
Bump up timeout on multi-feed test for CI
2023-01-10 11:09:19 -05:00
Tyler Goodlet
e348968113
Add multi-broker streaming test using both `binance` and `kraken`
2023-01-10 11:09:19 -05:00
Tyler Goodlet
36868bb86e
Add `kraken` test, ensure single broker-provider for now
2023-01-10 11:09:19 -05:00
Tyler Goodlet
bb6452b969
Further feed syncing fixes wrt to `Flumes`
...
Sync per-symbol sampler loop start to subscription registers such that
the loop can't start until the consumer's stream subscription is added;
the task-sync uses a `trio.Event`. This patch also drops a ton of
commented cruft.
Further adjustments needed to get parity with prior functionality:
- pass init msg 'symbol_info' field to the `Symbol.broker_info: dict`.
- ensure the `_FeedsBus._subscriptions` table uses the broker specific
(without brokername suffix) as keys for lookup so that the sampler
loop doesn't have to append in the brokername as a suffix.
- ensure the `open_feed_bus()` flumes-table-msg returned sent by
`tractor.Context.started()` uses the `.to_msg()` form of all flume
structs.
- ensure `maybe_open_feed()` uses `tractor.MsgStream.subscribe()` on all
`Flume.stream`s on cache hits using the
`tractor.trionics.gather_contexts()` helper.
2023-01-10 11:09:19 -05:00