Files
quantconnect--lean/Tests/Optimizer/OptimizationNodePacketTests.cs
Adalyat Nazirov a4f66628fd Lean Optimization interface in QCAlgorithm (#4923)
* initial commit

* run parametrized algorithm with command line parameters

* skeleton: top level structure

* OptimizationNodePacket scheme

* pass parameters as HashSet

* run Lean and read results

* call method on optimization completion

* refactor public interfaces

- close ParameterSet collection; allow only get operations
- explicit method to start LeanOptimizer

* synchronize RunLean method; the result could come in before the backtest id is set in the collections

* another portion of refactoring and interface changes

* comments

* comments & tests for Extremum, Minimization and Maximization classes

* unify optimization paramater values (min, max, step) & mode GridSearch tests

- swap min&max if necessary
- iterate left => right (negate step value if necessary) & provide default step value if step == 0
- no StackOverflow Exception
- parameterSet Id should be global for current generator and retain between steps
- test signle point boundary (min == max)

* BruteForceStrategy tests

* more comments

* Update Optimizer assembly information

- Update Optimizer projects assembly information to match behavior of
  the other projects

* Tweaks

- Adding comments
- Replace OnComplete for Ended event
- Replace Abort for Dispose
- ConsoleLeanOptimizer will keep track of running processes
- Each backtest will store results in a separated directory, so they
  don't fight for the log.txt file.
- Adding cmdline option for lean to close automatically
- Adding concurrent execution backtest limit
- Console optimizer will start Lean minimized
- Escape spaces in Json path

* remove parameter set generator abstraction layer

we don't need this flexibility now.

* refactor public methods; Step shouldn't be public

* constraints: wip

* define contract

* comparison operators and tests

* specify JsonProperty values

* Move SafeMultiply100 to extensions

* Throw exception on failed Optimizer.Start

* constraints: wip

* change finish & dispose process

* minor fixes

- handle force lean abort
- notify consumer if target has been reached

* target & constraints; adapt unit tests

* Minor Tweaks and fixes

- Some logging improvements
- Remove Public since not required

* Ignore empty ParameterValue

* simplify condition

* avoid reinitialization

* reduce type; force immutable

* unit tests for constraints  and target value

* parse & normalize percent values, i.e. 20% => 0.2

* fixup

* Target & Constraint & OptimizationNodePacket unit tests

* Add more json unit tests

- Adding more json conversion unit tests. Fix bug for Extremum which
  wasn't using the converter.

* LeanOptimizer tests

* Estimation results

* User thread safe counters

* LeanOptimizer unit tests; push OptimizationResult on Ended event

* more unit tests

* Minor tweaks

-Estimate ToString in a single line.
-Typos and missing header file

* Add base SendUpdate method

- Add base SendUpdate method for LeanOptimizer

* fix LeanOptimizer test; rely on internal Update rather than timer

* Add OptimizationStatus

- Add missing commments and OptimizationStatus

* EulerSearch implementation: wip

* OptimizationParameter custom converter

* change the type

* make step optional

* change folder structure

* enumerate optimization parameter using IEnumerable & IEnumerator

* unit tests: parameters & objectives

* unit tests: strategies

* remove redundant TODO

* change Euler search boundaries

* more Euler tests

* prevent race condition

* Add account/read endpoint

- Adding account/read endpoint. Adding unit test

* Add status check before running lean

* Minor self review

- Adding missing comments, minor changes

* remove array parameters

* minor changes

- tidy up config file, rename variable
- accept min less or equal than max

* move OptimizationParameter methods to strategies

* Minor improvements for BaseResultHandler derivates

* minor changes

- strict requirements for Step and MinStep values
- strategy specific settigs

* Add TotalRuntime to estimate

Co-authored-by: Martin Molinero <martin.molinero1@gmail.com>
2020-12-02 20:10:40 -03:00

138 lines
7.3 KiB
C#

/*
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using Newtonsoft.Json;
using NUnit.Framework;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using QuantConnect.Optimizer;
using QuantConnect.Optimizer.Parameters;
using QuantConnect.Optimizer.Objectives;
using QuantConnect.Optimizer.Strategies;
using QuantConnect.Packets;
using QuantConnect.Util;
namespace QuantConnect.Tests.Optimizer
{
[TestFixture, Parallelizable(ParallelScope.All)]
public class OptimizationNodePacketTest
{
private static JsonSerializerSettings _jsonSettings = new JsonSerializerSettings() { Culture = CultureInfo.InvariantCulture };
[TestCase("QuantConnect.Optimizer.EulerSearchOptimizationStrategy", typeof(StepBaseOptimizationStrategySettings))]
[TestCase("QuantConnect.Optimizer.GridSearchOptimizationStrategy", typeof(OptimizationStrategySettings))]
public void RoundTrip(string strategyName, Type settingType)
{
var optimizationNodePacket = new OptimizationNodePacket()
{
CompileId = Guid.NewGuid().ToString(),
OptimizationId = Guid.NewGuid().ToString(),
OptimizationStrategy = strategyName,
Criterion = new Target("Profit", new Maximization(), 100.5m),
Constraints = new List<Constraint>
{
new Constraint("Drawdown", ComparisonOperatorTypes.LessOrEqual, 0.1m),
new Constraint("Profit", ComparisonOperatorTypes.Greater, 100)
},
OptimizationParameters = new HashSet<OptimizationParameter>()
{
new OptimizationStepParameter("ema-slow", 1, 100, 1m),
new OptimizationStepParameter("ema-fast", -10, 0, 0.5m)
},
MaximumConcurrentBacktests = 10,
OptimizationStrategySettings = (OptimizationStrategySettings)Activator.CreateInstance(settingType)
};
var serialize = JsonConvert.SerializeObject(optimizationNodePacket, _jsonSettings);
var result = JsonConvert.DeserializeObject<OptimizationNodePacket>(serialize, _jsonSettings);
// common
Assert.AreEqual(PacketType.OptimizationNode, result.Type);
// assert strategy
Assert.AreEqual(optimizationNodePacket.OptimizationStrategy, result.OptimizationStrategy);
Assert.AreEqual(optimizationNodePacket.OptimizationId, result.OptimizationId);
Assert.AreEqual(optimizationNodePacket.CompileId, result.CompileId);
// assert optimization parameters
foreach (var expected in optimizationNodePacket.OptimizationParameters.OfType<OptimizationStepParameter>())
{
var actual = result.OptimizationParameters.FirstOrDefault(s => s.Name == expected.Name) as OptimizationStepParameter;
Assert.NotNull(actual);
Assert.AreEqual(expected.MinValue, actual.MinValue);
Assert.AreEqual(expected.MaxValue, actual.MaxValue);
Assert.AreEqual(expected.Step, actual.Step);
}
// assert target
Assert.AreEqual(optimizationNodePacket.Criterion.Target, result.Criterion.Target);
Assert.AreEqual(optimizationNodePacket.Criterion.Extremum.GetType(), result.Criterion.Extremum.GetType());
Assert.AreEqual(optimizationNodePacket.Criterion.TargetValue, result.Criterion.TargetValue);
// assert constraints
foreach (var expected in optimizationNodePacket.Constraints)
{
var actual = result.Constraints.FirstOrDefault(s => s.Target == expected.Target);
Assert.NotNull(actual);
Assert.AreEqual(expected.Operator, actual.Operator);
Assert.AreEqual(expected.TargetValue, actual.TargetValue);
}
// others
Assert.AreEqual(optimizationNodePacket.MaximumConcurrentBacktests, result.MaximumConcurrentBacktests);
Assert.AreEqual(settingType, result.OptimizationStrategySettings.GetType());
}
[TestCase("StepBaseOptimizationStrategySettings")]
[TestCase("OptimizationStrategySettings")]
public void FromJson(string settingTypeName)
{
var json = "{\"OptimizationParameters\": [{\"Name\":\"sleep-ms\",\"min\":0,\"max\":0,\"Step\":1}," +
"{\"Name\":\"total-trades\",\"min\":0,\"max\":2,\"Step\":1}]," +
"\"criterion\": {\"extremum\" : \"min\",\"target\": \"Statistics.Sharpe Ratio\",\"target-value\": 10}," +
"\"constraints\": [{\"target\": \"Statistics.Sharpe Ratio\",\"operator\": \"equals\",\"target-value\": 11}],"+
$"\"optimizationStrategySettings\":{{\"$type\":\"QuantConnect.Optimizer.Strategies.{settingTypeName}, QuantConnect.Optimizer\",\"default-segment-amount\":0,\"max-run-time\":\"10675199.02:48:05.4775807\"}}}}";
var packet = (OptimizationNodePacket)JsonConvert.DeserializeObject(json, typeof(OptimizationNodePacket));
Assert.AreEqual("['Statistics'].['Sharpe Ratio']", packet.Criterion.Target);
Assert.AreEqual(typeof(Minimization), packet.Criterion.Extremum.GetType());
Assert.AreEqual(2, packet.OptimizationParameters.Count);
Assert.AreEqual(1, packet.Constraints.Count);
Assert.AreEqual("['Statistics'].['Sharpe Ratio']", packet.Constraints.Single().Target);
Assert.AreEqual(settingTypeName, packet.OptimizationStrategySettings.GetType().Name);
}
[Test]
public void FromJsonNoSettings()
{
var json = "{\"OptimizationParameters\": [{\"Name\":\"sleep-ms\",\"min\":0,\"max\":0,\"Step\":1}," +
"{\"Name\":\"total-trades\",\"min\":0,\"max\":2,\"Step\":1}]," +
"\"criterion\": {\"extremum\" : \"min\",\"target\": \"Statistics.Sharpe Ratio\",\"target-value\": 10}," +
"\"constraints\": [{\"target\": \"Statistics.Sharpe Ratio\",\"operator\": \"equals\",\"target-value\": 11}]}";
var packet = (OptimizationNodePacket)JsonConvert.DeserializeObject(json, typeof(OptimizationNodePacket));
Assert.AreEqual("['Statistics'].['Sharpe Ratio']", packet.Criterion.Target);
Assert.AreEqual(typeof(Minimization), packet.Criterion.Extremum.GetType());
Assert.AreEqual(2, packet.OptimizationParameters.Count);
Assert.AreEqual(1, packet.Constraints.Count);
Assert.AreEqual("['Statistics'].['Sharpe Ratio']", packet.Constraints.Single().Target);
Assert.IsNull(packet.OptimizationStrategySettings);
}
}
}