Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Prod Release 06/02/24 #546

Merged
merged 25 commits into from
Feb 6, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
25 commits
Select commit Hold shift + click to select a range
c71b7d1
fix: upgrade @next/font from 13.1.6 to 13.5.3
snyk-bot Oct 21, 2023
d4ff2ba
fix: upgrade @types/node from 18.13.0 to 18.18.1
snyk-bot Oct 21, 2023
d4c40e2
fix: upgrade @types/react from 18.0.28 to 18.2.23
snyk-bot Oct 21, 2023
64c06e5
fix: upgrade eslint from 8.34.0 to 8.50.0
snyk-bot Oct 21, 2023
34cb33d
fix: frontend/package.json to reduce vulnerabilities
snyk-bot Oct 26, 2023
aac2273
feat: Capture errors thrown within Coordinator (#515)
morgsmccauley Jan 24, 2024
acec01a
feat: Only start indexers set within the `allowlist` (#518)
morgsmccauley Jan 24, 2024
32d6fa9
feat: Add `Dockerfile` for Coordinator V2 (#519)
morgsmccauley Jan 24, 2024
a431a77
feat: Support Deployment of Block Streamer (#516)
darunrs Jan 25, 2024
920407a
feat: Enable Block Streams Start from V1 Interruption (#517)
darunrs Jan 25, 2024
0b6c08a
Merge branch 'main' into snyk-upgrade-4ba709d36fa2e38a5ac1105f6ae38549
Kevin101Zhang Jan 25, 2024
c5b1e41
Merge pull request #314 from near/snyk-upgrade-4ba709d36fa2e38a5ac110…
Kevin101Zhang Jan 25, 2024
f568bd0
Merge branch 'main' into snyk-upgrade-c7dc22e6846ada68552465a4cbc363b0
Kevin101Zhang Jan 25, 2024
a23c51e
Merge pull request #313 from near/snyk-upgrade-c7dc22e6846ada68552465…
Kevin101Zhang Jan 25, 2024
46e363c
feat: Logging & Error updates (#526)
morgsmccauley Jan 25, 2024
b6fc249
Merge branch 'main' into snyk-upgrade-a7fd032540f59a0e0521b8386f1e3465
Kevin101Zhang Jan 26, 2024
6116c53
Merge pull request #315 from near/snyk-upgrade-a7fd032540f59a0e0521b8…
Kevin101Zhang Jan 26, 2024
2317f36
Merge pull request #334 from near/snyk-fix-415cfdc1a838c227b64a7b254d…
Kevin101Zhang Jan 26, 2024
102409a
Merge branch 'main' into snyk-upgrade-fdf2121163d14312e34f796d4e4ec0e4
Kevin101Zhang Jan 26, 2024
70ea36d
Merge pull request #316 from near/snyk-upgrade-fdf2121163d14312e34f79…
Kevin101Zhang Jan 26, 2024
593f305
fix: Prevent Coordinator from stopping V1 executors (#544)
morgsmccauley Jan 31, 2024
10e2963
fix: Resolve duplicate processing of messages in Runner (#545)
darunrs Feb 1, 2024
2c28dc3
fix: Executors would crash when DmlHandler.create times out (#547)
darunrs Feb 5, 2024
9ef1f29
feat: Auto migrate indexers to Control Plane (#527)
morgsmccauley Feb 6, 2024
fd64a8c
fix: Crashed Runner Executors would continue to display RUNNING (#550)
darunrs Feb 6, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .dockerignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
**/target

19 changes: 19 additions & 0 deletions block-streamer/Dockerfile
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
FROM rust:1.75 AS build
ARG CARGO_BUILD_MODE=release
WORKDIR /tmp/
COPY block-streamer/ block-streamer/
COPY registry/types/ registry/types/
WORKDIR /tmp/block-streamer/
RUN apt update && apt install -yy protobuf-compiler
RUN if [ "$CARGO_BUILD_MODE" = "debug" ]; then \
cargo build --package block-streamer; \
else \
cargo build --release --package block-streamer; \
fi

FROM ubuntu:22.04
ARG CARGO_BUILD_MODE=release
RUN apt update && apt install -yy openssl ca-certificates
USER nobody
COPY --from=build /tmp/block-streamer/target/$CARGO_BUILD_MODE/block-streamer /block-streamer
ENTRYPOINT ["/block-streamer"]
2 changes: 2 additions & 0 deletions block-streamer/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,14 @@ async fn main() -> anyhow::Result<()> {

tracing::info!("Starting Block Streamer Service...");

tracing::info!("Connecting to Redis...");
let redis_client = std::sync::Arc::new(redis::RedisClient::connect(&redis_url).await?);

let aws_config = aws_config::from_env().load().await;
let s3_config = aws_sdk_s3::Config::from(&aws_config);
let s3_client = crate::s3_client::S3Client::new(s3_config.clone());

tracing::info!("Connecting to Delta Lake...");
let delta_lake_client =
std::sync::Arc::new(crate::delta_lake_client::DeltaLakeClient::new(s3_client));

Expand Down
2 changes: 1 addition & 1 deletion block-streamer/src/server/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ pub async fn init(
delta_lake_client: std::sync::Arc<crate::delta_lake_client::DeltaLakeClient>,
lake_s3_config: aws_sdk_s3::Config,
) -> anyhow::Result<()> {
let addr = format!("[::1]:{}", port).parse()?;
let addr = format!("0.0.0.0:{}", port).parse()?;

tracing::info!("Starting RPC server at {}", addr);

Expand Down
Loading
Loading