/* * 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 System.Collections.Generic; using System.Diagnostics; using System.IO; using Python.Runtime; namespace QuantConnect.Python { /// /// Helper class for Python initialization /// public static class PythonInitializer { // Used to allow multiple Python unit and regression tests to be run in the same test run private static bool _initialized; /// /// Initialize the Python.NET library /// public static void Initialize(string assemblyPath = "") { if (!_initialized) { if (assemblyPath != string.Empty) { // Set the python path for loading python algorithms. var pythonPath = new List { new FileInfo(assemblyPath).Directory.FullName, new DirectoryInfo(Environment.CurrentDirectory).FullName, }; // Don't include an empty environment variable in pythonPath, otherwise the PYTHONPATH // environment variable won't be used in the module import process var pythonPathEnvironmentVariable = Environment.GetEnvironmentVariable("PYTHONPATH"); if (!string.IsNullOrEmpty(pythonPathEnvironmentVariable)) { pythonPath.Add(pythonPathEnvironmentVariable); } Environment.SetEnvironmentVariable("PYTHONPATH", string.Join(OS.IsLinux ? ":" : ";", pythonPath)); } var benchmark = Stopwatch.StartNew(); PythonEngine.Initialize(); Logging.Log.Trace("PythonInitializer.Initialize(): Python Engine Initialized in " + benchmark.Elapsed.TotalSeconds + "s. Thread: " + System.Threading.Thread.CurrentThread.Name); benchmark.Restart(); // required for multi-threading usage PythonEngine.BeginAllowThreads(); Logging.Log.Trace("PythonInitializer.Initialize(): Allow threading completed in " + benchmark.Elapsed.TotalSeconds + "s. Thread: " + System.Threading.Thread.CurrentThread.Name); _initialized = true; } } } }