forked from QuantConnect/lean-cli
-
Notifications
You must be signed in to change notification settings - Fork 0
/
build.py
182 lines (142 loc) · 8.18 KB
/
build.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
# QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
# Lean CLI v1.0. Copyright 2021 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.
import re
from pathlib import Path
from typing import Optional
import click
from lean.click import LeanCommand, PathParameter
from lean.container import container
from lean.models.docker import DockerImage
def _normalize_newlines(text: str) -> str:
"""Normalizes the newlines in a string to use \n (instead of \r or \r\n).
:param text: the text to normalize the newlines in
:return: the text with the newlines normalized
"""
return "\n".join(text.splitlines())
def _is_foundation_dockerfile_same_as_cloud(dockerfile: Path) -> bool:
"""Checks whether a Dockerfile is the same as the Dockerfile used for the quantconnect/lean:foundation image.
:param dockerfile: the path to the local Dockerfile to check
:return: whether the local Dockerfile is the same as the one used for the quantconnect/lean:foundation image
"""
local_dockerfile = dockerfile.read_text(encoding="utf-8").strip()
try:
cloud_url = f"https://raw.githubusercontent.com/QuantConnect/Lean/master/{dockerfile.name}"
cloud_dockerfile = container.http_client().get(cloud_url)
cloud_dockerfile = cloud_dockerfile.text.strip()
except:
# We build a new image if for whatever reason we can't check the Dockerfile used for the official image
return False
return _normalize_newlines(local_dockerfile) == _normalize_newlines(cloud_dockerfile)
def _compile_csharp(root: Path, csharp_dir: Path, docker_image: DockerImage) -> None:
"""Compiles C# code.
:param root: the root directory in which the command is ran
:param csharp_dir: the directory containing the C# code
:param docker_image: the Docker image to compile in
"""
logger = container.logger()
logger.info(f"Compiling the C# code in '{csharp_dir}'")
build_path = Path("/LeanCLI") / csharp_dir.relative_to(root)
docker_manager = container.docker_manager()
docker_manager.create_volume("lean_cli_nuget")
success = docker_manager.run_image(docker_image,
entrypoint=["dotnet", "build", str(build_path)],
environment={
"DOTNET_CLI_TELEMETRY_OPTOUT": "true",
"DOTNET_NOLOGO": "true"
},
volumes={
str(root): {
"bind": "/LeanCLI",
"mode": "rw"
},
"lean_cli_nuget": {
"bind": "/root/.nuget/packages",
"mode": "rw"
}
})
if not success:
raise RuntimeError("Something went wrong while running dotnet build, see the logs above for more information")
def _build_image(root: Path, dockerfile: Path, base_image: Optional[DockerImage], target_image: DockerImage) -> None:
"""Builds a Docker image.
:param root: the path to build from
:param dockerfile: the path to the Dockerfile to build
:param base_image: the base image to use, or None if the default should be used
:param target_image: the name of the new image
"""
logger = container.logger()
if base_image is not None:
logger.info(f"Building '{target_image}' from '{dockerfile}' using '{base_image}' as base image")
else:
logger.info(f"Building '{target_image}' from '{dockerfile}'")
if not dockerfile.is_file():
raise RuntimeError(f"'{dockerfile}' does not exist")
current_content = dockerfile.read_text(encoding="utf-8")
if base_image is not None:
new_content = re.sub(r"^FROM.*$", f"FROM {base_image}", current_content, flags=re.MULTILINE)
dockerfile.write_text(new_content, encoding="utf-8")
try:
docker_manager = container.docker_manager()
docker_manager.build_image(root, dockerfile, target_image)
finally:
if base_image is not None:
dockerfile.write_text(current_content, encoding="utf-8")
@click.command(cls=LeanCommand, requires_docker=True)
@click.argument("root", type=PathParameter(exists=True, file_okay=False, dir_okay=True), default=lambda: Path.cwd())
@click.option("--tag", type=str, default="latest", help="The tag to apply to custom images (defaults to latest)")
def build(root: Path, tag: str) -> None:
"""Build Docker images of your own version of LEAN and the Alpha Streams SDK.
\b
ROOT must point to a directory containing the LEAN repository and the Alpha Streams SDK repository:
https://github.com/QuantConnect/Lean & https://github.com/QuantConnect/AlphaStreams
When ROOT is not given, the current directory is used as root directory.
\b
This command performs the following actions:
1. The lean-cli/foundation:latest image is built from Lean/DockerfileLeanFoundation(ARM).
2. LEAN is compiled in a Docker container using the lean-cli/foundation:latest image.
3. The Alpha Streams SDK is compiled in a Docker container using the lean-cli/foundation:latest image.
4. The lean-cli/engine:latest image is built from Lean/Dockerfile using lean-cli/foundation:latest as base image.
5. The lean-cli/research:latest image is built from Lean/DockerfileJupyter using lean-cli/engine:latest as base image.
6. The default engine image is set to lean-cli/engine:latest.
7. The default research image is set to lean-cli/research:latest.
When the foundation Dockerfile is the same as the official foundation Dockerfile,
quantconnect/lean:foundation is used instead of building a custom foundation image.
"""
lean_dir = root / "Lean"
if not lean_dir.is_dir():
raise RuntimeError(f"Please clone https://github.com/QuantConnect/Lean to '{lean_dir}'")
alpha_streams_dir = root / "AlphaStreams"
if not lean_dir.is_dir():
raise RuntimeError(f"Please clone https://github.com/QuantConnect/AlphaStreams to '{alpha_streams_dir}'")
(root / "DataLibraries").mkdir(exist_ok=True)
if container.platform_manager().is_host_arm():
foundation_dockerfile = lean_dir / "DockerfileLeanFoundationARM"
else:
foundation_dockerfile = lean_dir / "DockerfileLeanFoundation"
if _is_foundation_dockerfile_same_as_cloud(foundation_dockerfile):
foundation_image = DockerImage(name="quantconnect/lean", tag="foundation")
container.docker_manager().pull_image(foundation_image)
else:
foundation_image = DockerImage(name="lean-cli/foundation", tag=tag)
_build_image(root, foundation_dockerfile, None, foundation_image)
_compile_csharp(root, lean_dir, foundation_image)
_compile_csharp(root, alpha_streams_dir, foundation_image)
custom_engine_image = DockerImage(name="lean-cli/engine", tag=tag)
_build_image(root, lean_dir / "Dockerfile", foundation_image, custom_engine_image)
custom_research_image = DockerImage(name="lean-cli/research", tag=tag)
_build_image(root, lean_dir / "DockerfileJupyter", custom_engine_image, custom_research_image)
logger = container.logger()
cli_config_manager = container.cli_config_manager()
logger.info(f"Setting default engine image to '{custom_engine_image}'")
cli_config_manager.engine_image.set_value(str(custom_engine_image))
logger.info(f"Setting default research image to '{custom_research_image}'")
cli_config_manager.research_image.set_value(str(custom_research_image))