Commit Graph

106 Commits (paper_trade_improvements_rebase)

Author SHA1 Message Date
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