Serialized Message Consumer #26700

cgardens · 2023-05-27T05:33:37Z

What

As part of the async version of the Snowflake Destination, instead of passing the already deserialized messages to the message consumer, we need to pass the raw string (and its size in bytes).
This PR changes adds a new consumer to the Destination interface that does just (SerializedAirbyteMessageConsumer). It is default to just delegate to the old AirbyteMessageConsumer. This makes it backwards compatible and a no op for existing Destinations. The IntegrationRunner to calls the interface method on the Destination.
I have left the code (but commented out) in SnowflakeDestination.java for how we would turn on the async version of the Snowflake Destination. As we roll it out with the feature flag, those 3 lines of code will all that needs to be maintained on the feature branch.

🚨 User Impact 🚨

No! That's the whole point of this PR it's a no op from the user's point of view, but sets up the async snowflake destination.

github-actions · 2023-05-27T05:38:50Z

Affected Connector Report

NOTE ⚠️ Changes in this PR affect the following connectors. Make sure to do the following as needed:

Run integration tests
Bump connector or module version
Add changelog
Publish the new version

✅ Sources (33)

Connector	Version	Changelog	Publish
`source-alloydb`	`2.0.28`	✅	✅
`source-alloydb-strict-encrypt`	`2.0.28`	🔵 (ignored)	🔵 (ignored)
`source-azure-blob-storage`	`0.1.0`	✅	✅
`source-bigquery`	`0.2.3`	✅	✅
`source-clickhouse`	`0.1.17`	✅	✅
`source-clickhouse-strict-encrypt`	`0.1.17`	🔵 (ignored)	🔵 (ignored)
`source-cockroachdb`	`0.1.22`	✅	✅
`source-cockroachdb-strict-encrypt`	`0.1.22`	🔵 (ignored)	🔵 (ignored)
`source-db2`	`0.1.19`	✅	✅
`source-db2-strict-encrypt`	`0.1.19`	🔵 (ignored)	🔵 (ignored)
`source-dynamodb`	`0.1.2`	✅	✅
`source-e2e-test`	`2.1.4`	✅	✅
`source-e2e-test-cloud`	`2.1.4`	🔵 (ignored)	🔵 (ignored)
`source-elasticsearch`	`0.1.1`	✅	✅
`source-jdbc`	`0.3.5`	🔵 (ignored)	🔵 (ignored)
`source-kafka`	`0.2.3`	✅	✅
`source-mongodb-strict-encrypt`	`0.1.19`	🔵 (ignored)	🔵 (ignored)
`source-mongodb-v2`	`0.1.19`	✅	✅
`source-mssql`	`1.0.17`	✅	✅
`source-mssql-strict-encrypt`	`1.0.17`	🔵 (ignored)	🔵 (ignored)
`source-mysql`	`2.0.24`	✅	✅
`source-mysql-strict-encrypt`	`2.0.24`	🔵 (ignored)	🔵 (ignored)
`source-oracle`	`0.3.24`	✅	✅
`source-oracle-strict-encrypt`	`0.3.24`	🔵 (ignored)	🔵 (ignored)
`source-postgres`	`2.0.31`	✅	✅
`source-postgres-strict-encrypt`	`2.0.31`	🔵 (ignored)	🔵 (ignored)
`source-redshift`	`0.3.16`	✅	✅
`source-relational-db`	`0.3.1`	🔵 (ignored)	🔵 (ignored)
`source-scaffold-java-jdbc`	`0.1.0`	🔵 (ignored)	🔵 (ignored)
`source-sftp`	`0.1.2`	✅	✅
`source-snowflake`	`0.1.34`	✅	✅
`source-teradata`	`0.1.0`	✅	✅
`source-tidb`	`0.2.4`	✅	✅

See "Actionable Items" below for how to resolve warnings and errors.

❌ Destinations (50)

Connector	Version	Changelog	Publish
`destination-azure-blob-storage`	`0.2.0`	✅	✅
`destination-bigquery`	`1.4.4`	✅	✅
`destination-bigquery-denormalized`	`1.4.1`	✅	✅
`destination-cassandra`	`0.1.4`	✅	✅
`destination-clickhouse`	`0.2.3`	✅	✅
`destination-clickhouse-strict-encrypt`	`0.2.3`	🔵 (ignored)	🔵 (ignored)
`destination-csv`	`1.0.0`	✅	✅
`destination-databricks`	`1.0.2`	✅	✅
`destination-dev-null`	`0.3.0`	🔵 (ignored)	🔵 (ignored)
`destination-doris`	`0.1.0`	✅	✅
`destination-dynamodb`	`0.1.7`	✅	✅
`destination-e2e-test`	`0.3.0`	✅	✅
`destination-elasticsearch`	`0.1.6`	✅	✅
`destination-elasticsearch-strict-encrypt`	`0.1.6`	🔵 (ignored)	🔵 (ignored)
`destination-exasol`	`0.1.1`	✅	✅
`destination-gcs`	`0.3.0`	✅	✅
`destination-iceberg`	`0.1.0`	✅	✅
`destination-kafka`	`0.1.10`	✅	✅
`destination-keen`	`0.2.4`	✅	✅
`destination-kinesis`	`0.1.5`	✅	✅
`destination-local-json`	`0.2.11`	✅	✅
`destination-mariadb-columnstore`	`0.1.7`	✅	✅
`destination-mongodb`	`0.1.9`	✅	✅
`destination-mongodb-strict-encrypt`	`0.1.9`	🔵 (ignored)	🔵 (ignored)
`destination-mqtt`	`0.1.3`	✅	✅
`destination-mssql`	`0.1.23`	✅	✅
`destination-mssql-strict-encrypt`	`0.1.23`	🔵 (ignored)	🔵 (ignored)
`destination-mysql`	`0.1.20`	✅	✅
`destination-mysql-strict-encrypt`	❌ `0.1.21` (mismatch: `0.1.20`)	🔵 (ignored)	🔵 (ignored)
`destination-oracle`	`0.1.19`	✅	✅
`destination-oracle-strict-encrypt`	`0.1.19`	🔵 (ignored)	🔵 (ignored)
`destination-postgres`	`0.3.27`	✅	✅
`destination-postgres-strict-encrypt`	`0.3.27`	🔵 (ignored)	🔵 (ignored)
`destination-pubsub`	`0.2.0`	✅	✅
`destination-pulsar`	`0.1.3`	✅	✅
`destination-r2`	`0.1.0`	✅	✅
`destination-redis`	`0.1.4`	✅	✅
`destination-redpanda`	`0.1.0`	✅	✅
`destination-redshift`	`0.4.8`	✅	✅
`destination-rockset`	`0.1.4`	✅	✅
`destination-s3`	`0.4.1`	✅	✅
`destination-s3-glue`	`0.1.7`	✅	✅
`destination-scylla`	`0.1.3`	✅	✅
`destination-selectdb`	`0.1.0`	✅	✅
`destination-snowflake`	`1.0.4`	✅	✅
`destination-starburst-galaxy`	`0.0.1`	✅	✅
`destination-teradata`	`0.1.1`	✅	✅
`destination-tidb`	`0.1.1`	✅	❌ (diff seed version)
`destination-vertica`	`0.1.0`	✅	✅
`destination-yugabytedb`	`0.1.1`	✅	✅

See "Actionable Items" below for how to resolve warnings and errors.

👀 Other Modules (1)

base-normalization

Actionable Items

(click to expand)

Category	Status	Actionable Item
Version	❌ mismatch	The version of the connector is different from its normal variant. Please bump the version of the connector.
	⚠ doc not found	The connector does not seem to have a documentation file. This can be normal (e.g. basic connector like `source-jdbc` is not published or documented). Please double-check to make sure that it is not a bug.
Changelog	⚠ doc not found	The connector does not seem to have a documentation file. This can be normal (e.g. basic connector like `source-jdbc` is not published or documented). Please double-check to make sure that it is not a bug.
	❌ changelog missing	There is no chnagelog for the current version of the connector. If you are the author of the current version, please add a changelog.
Publish	⚠ not in seed	The connector is not in the cloud or oss registry, so its publication status cannot be checked. This can be normal (e.g. some connectors are cloud-specific, and only listed in the cloud seed file). Please double-check to make sure that you have added a metadata.yaml file and the expected registries are enabled.

cgardens · 2023-05-27T06:08:22Z

...wflake/src/main/java/io/airbyte/integrations/destination/snowflake/SnowflakeDestination.java

+    // final boolean useAsyncSnowflake = config.has("loading_method")
+    // && config.get("loading_method").has("method")
+    // && config.get("loading_method").get("method").asText().equals("Internal Staging");


uncommenting these lines of code will all we will need to do to "turn on" the async version of the destination. as we do a feature flagged roll out, this will be the only diff in that feature branch.

davinchia · 2023-05-29T18:20:59Z

...s/base-java/src/main/java/io/airbyte/integrations/base/SerializedAirbyteMessageConsumer.java

+   * @throws Exception exception
+   */
+  @Override
+  void accept(String message, Integer sizeInBytes) throws Exception;


thought: should sizeInBytes be a long instead of an int? although seems very unlikely we'd have a record > 2.3GB, not sure we want to bake this assumption into the interface. might be useful for this to be more flexible.

i don't have a strong opinion. i think we said fivetran limits record size to 200MB, so that seems like it gives us a fair amount of buffer. happy to swtich it.

davinchia · 2023-05-29T18:36:34Z

...yte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/Destination.java

+     * If the provided JSON string is invalid AND represents a {@link AirbyteMessage.Type#STATE}
+     * message, processing is halted. Otherwise, the invalid message is logged and execution continues.


nit: probably useful to add more details why i.e. STATE messages represent application state and we want to fail fast to ensure data correctness.

ah - didn't realise this was moved from an existing class.

...yte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/Destination.java

davinchia · 2023-05-29T18:43:32Z

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

-          }
+
+          final Procedure consumeWriteStreamCallable = () -> {
+            try (final SerializedAirbyteMessageConsumer consumer = destination.getSerializedMessageConsumer(config, catalog, outputRecordCollector)) {


for understanding: after this merge, we should be able to get rid of getConsumer?

we can only get rid of getConsumer once all destinations are migrated over to use the new thing. but for snowflake, yes, in subsequent PRs it overrides this method instead.

davinchia · 2023-05-29T18:45:00Z

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

+      throws Exception {
+    consumer.start();
+
+    final byte[] buffer = new byte[8192]; // 8K buffer


any specific reason to use 8k?

is this from somewhere else? looks familiar.

8k bytes is the default buffer size for BufferedInputStream

+1 to what ryan said.

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

davinchia

I'm not 100% the shim is in the right place. It looks like SwitchingDestination is where this should go. I don't think this is blocking.

edgao

the manual system.in parsing scares me. Open to being convinced that I'm being overcautious though.

other than that, agree that this is a noop. had a few comments for my own learning + one nitpick.

...yte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/Destination.java

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

edgao · 2023-05-30T18:28:24Z

/test connector=connectors/destination-snowflake

🕑 connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5125001361
❌ connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5125001361
🐛 https://gradle.com/s/kw33vs3dw7ohe

Build Failed

Test summary info:

Could not find result summary

edgao · 2023-05-30T18:28:33Z

/test connector=connectors/destination-bigquery

🕑 connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5125003045
❌ connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5125003045
🐛 https://gradle.com/s/7ud3wmlloai7i

Build Failed

Test summary info:

Could not find result summary

…integrations/base/Destination.java Co-authored-by: Edward Gao <edward.gao@airbyte.io>

…integrations/base/Destination.java Co-authored-by: Davin Chia <davinchia@gmail.com>

cgardens · 2023-05-30T22:33:58Z

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

+            }
+          };
+
+          watchForOrphanThreads(


for context, we moved this because on master it is getting called before the close is called on the destination. this doesn't make sense, because it is checking if the destination cleaned itself up properly. that's a ridiculous thing to change before you let the destination call close. now this only gets called after the destination calls close

…integrations/base/IntegrationRunner.java Co-authored-by: Davin Chia <davinchia@gmail.com>

evantahler

None of my comments are blocking, but the /test seems to be failing:

BigQueryStandardDestinationAcceptanceTest > testCustomDbtTransformations() FAILED
    io.airbyte.workers.exception.TestHarnessException: dbt debug Failed.
        at app//io.airbyte.integrations.standardtest.destination.DestinationAcceptanceTest.testCustomDbtTransformations(DestinationAcceptanceTest.java:967)

So something isn't working quite right

evantahler · 2023-05-30T22:36:02Z

...yte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/Destination.java

+        if (isStateMessage(inputString)) {
+          throw new IllegalStateException("Invalid state message: " + inputString);
+        } else {
+          log.error("Received invalid message: " + inputString);
+        }


👍 I believe that all other types of messages that a source might emit (log, control, etc) should not be passed to the destination, so STATE messages are the only other types to check for which are meaningful

evantahler · 2023-05-30T22:38:04Z

...yte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/Destination.java

+     */
+    @SuppressWarnings("OptionalIsPresent")
+    private static boolean isStateMessage(final String input) {
+      final Optional<AirbyteTypeMessage> deserialized = Jsons.tryDeserialize(input, AirbyteTypeMessage.class);


I'm sure you tested this, but just for my own understanding, how does this work? Since there's only one top-level property, with the JSON parser only deser the top level, leaving RECORD: {} as a string?

cc @davinchia remember when we tried this in mexico with just string.contains()? this is much better

yeah exactly. it just deserializes type and ignores the rest.

fwiw, jonathan pearlin is the one who set this up. this has been in prod for a while.

evantahler · 2023-05-30T22:43:09Z

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java

+    while ((bytesRead = bis.read(buffer)) != -1) {
+      for (int i = 0; i < bytesRead; i++) {
+        final byte b = buffer[i];
+        if (b == '\n' || b == '\r') {


[nit] Any worries about "encoded" newline characters within the records themselves ({body: "hello\nworld"})? Is there a builtin for sytem.newline or something like that?

I have a test in IntegrationRunnerBackwardsCompatbilityTest.java to make sure the behavior is the same between what we have on master and this branch to make sure we don't mess anything up.

cgardens · 2023-05-30T23:28:18Z

/test connector=connectors/destination-redshift

🕑 connectors/destination-redshift https://github.com/airbytehq/airbyte/actions/runs/5127201455
❌ connectors/destination-redshift https://github.com/airbytehq/airbyte/actions/runs/5127201455
🐛 https://gradle.com/s/lgdgr267tryow

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-30T23:32:13Z

/test connector=connectors/destination-snowflake

🕑 connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5127223755
❌ connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5127223755
🐛 https://gradle.com/s/ubyqihx2ubklq

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-30T23:32:22Z

/test connector=connectors/destination-bigquery

🕑 connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5127225203
❌ connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5127225203
🐛 https://gradle.com/s/5idbzkksfbg6k

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-30T23:33:33Z

running tests on "master" here to compare test results

This reverts commit 75240b0.

cgardens · 2023-05-31T03:31:46Z

/test connector=connectors/destination-redshift

🕑 connectors/destination-redshift https://github.com/airbytehq/airbyte/actions/runs/5128577294
❌ connectors/destination-redshift https://github.com/airbytehq/airbyte/actions/runs/5128577294
🐛 https://gradle.com/s/ghiub4y2uymnm

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-31T03:31:51Z

/test connector=connectors/destination-snowflake

🕑 connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5128577562
❌ connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5128577562
🐛 https://gradle.com/s/swzomntwcby7s

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-31T03:31:58Z

/test connector=connectors/destination-bigquery

🕑 connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5128578437
❌ connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5128578437
🐛 https://gradle.com/s/w7czo6hmeaglk

Build Failed

Test summary info:

Could not find result summary

…"" This reverts commit a89d5bc.

cgardens · 2023-05-31T06:08:15Z

/test connector=connectors/destination-redshift

🕑 connectors/destination-redshift https://github.com/airbytehq/airbyte/actions/runs/5129466717
❌ connectors/destination-redshift https://github.com/airbytehq/airbyte/actions/runs/5129466717
🐛 https://gradle.com/s/gj6zwtnlrmdau

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-31T06:08:25Z

/test connector=connectors/destination-snowflake

🕑 connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5129467836
❌ connectors/destination-snowflake https://github.com/airbytehq/airbyte/actions/runs/5129467836
🐛 https://gradle.com/s/7hnpp4if4ynyk

Build Failed

Test summary info:

Could not find result summary

cgardens · 2023-05-31T06:08:30Z

/test connector=connectors/destination-bigquery

🕑 connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5129468682
❌ connectors/destination-bigquery https://github.com/airbytehq/airbyte/actions/runs/5129468682
🐛 https://gradle.com/s/7gwdy6c7eachu

Build Failed

Test summary info:

Could not find result summary

This reverts commit 81f44d9.

octavia-squidington-iii added area/connectors Connector related issues connectors/destination/snowflake connectors/source/e2e-test labels May 27, 2023

cgardens force-pushed the cgardens/serialized-message-consumer branch from 3dba253 to 70d6e01 Compare May 27, 2023 05:49

cgardens requested review from evantahler, edgao, davinchia and ryankfu May 27, 2023 05:50

cgardens removed the connectors/source/e2e-test label May 27, 2023

cgardens force-pushed the cgardens/serialized-message-consumer branch from cbc2852 to 4ccd5c7 Compare May 27, 2023 06:06

cgardens commented May 27, 2023

View reviewed changes

add serialized message consumer

ac71c2d

cgardens force-pushed the cgardens/serialized-message-consumer branch from 4ccd5c7 to ac71c2d Compare May 27, 2023 06:14

cgardens marked this pull request as ready for review May 27, 2023 06:15

cgardens requested review from a team as code owners May 27, 2023 06:15

davinchia reviewed May 29, 2023

View reviewed changes

...yte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/Destination.java Outdated Show resolved Hide resolved

davinchia reviewed May 29, 2023

View reviewed changes

...tegrations/bases/base-java/src/main/java/io/airbyte/integrations/base/IntegrationRunner.java Outdated Show resolved Hide resolved

davinchia approved these changes May 29, 2023

View reviewed changes

edgao reviewed May 30, 2023

View reviewed changes

This was referenced May 30, 2023

[Epic] Destination Snowflake to 10 MB/s #24788

Closed

Destination Snowflake: Merge all critical path PRs for Async Snowflake into master #26794

Closed

Update airbyte-integrations/bases/base-java/src/main/java/io/airbyte/…

d926b02

…integrations/base/Destination.java Co-authored-by: Edward Gao <edward.gao@airbyte.io>

Update airbyte-integrations/bases/base-java/src/main/java/io/airbyte/…

4d2c256

…integrations/base/Destination.java Co-authored-by: Davin Chia <davinchia@gmail.com>

cgardens commented May 30, 2023

View reviewed changes

Update airbyte-integrations/bases/base-java/src/main/java/io/airbyte/…

cc63891

…integrations/base/IntegrationRunner.java Co-authored-by: Davin Chia <davinchia@gmail.com>

evantahler reviewed May 30, 2023

View reviewed changes

Automated Change

07da74c

cgardens mentioned this pull request May 30, 2023

noop #26806

Closed

Revert "Multi-architecture normalization build (local) (#26677)"

a89d5bc

This reverts commit 75240b0.

octavia-squidington-iii added the normalization label May 31, 2023

Revert "Revert "Multi-architecture normalization build (local) (#26677)…

205ab60

…"" This reverts commit a89d5bc.

octavia-squidington-iii removed the normalization label May 31, 2023

use CountingInputStream instead

81f44d9

cgardens added 2 commits May 31, 2023 07:40

Revert "use CountingInputStream instead"

66896b9

This reverts commit 81f44d9.

remove unneeded count variable

bffb52d

cgardens merged commit 567f839 into master May 31, 2023

cgardens deleted the cgardens/serialized-message-consumer branch May 31, 2023 15:14

marcosmarxm pushed a commit to natalia-miinto/airbyte that referenced this pull request Jun 8, 2023

Serialized Message Consumer (airbytehq#26700)

99eb630

		* If the provided JSON string is invalid AND represents a {@link AirbyteMessage.Type#STATE}
		* message, processing is halted. Otherwise, the invalid message is logged and execution continues.

Serialized Message Consumer #26700

Serialized Message Consumer #26700

Conversation

cgardens commented May 27, 2023 • edited Loading

What

Recommended reading order

🚨 User Impact 🚨

github-actions bot commented May 27, 2023 • edited Loading

Affected Connector Report

✅ Sources (33)

❌ Destinations (50)

👀 Other Modules (1)

Actionable Items

Choose a reason for hiding this comment

davinchia May 29, 2023 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

davinchia left a comment

Choose a reason for hiding this comment

edgao left a comment

Choose a reason for hiding this comment

edgao commented May 30, 2023 • edited by github-actions bot Loading

Build Failed

edgao commented May 30, 2023 • edited by github-actions bot Loading

Build Failed

Choose a reason for hiding this comment

evantahler left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

cgardens commented May 30, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 30, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 30, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 30, 2023

cgardens commented May 31, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 31, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 31, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 31, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 31, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 31, 2023 • edited by github-actions bot Loading

Build Failed

cgardens commented May 27, 2023 •

edited

Loading

github-actions bot commented May 27, 2023 •

edited

Loading

davinchia May 29, 2023 •

edited

Loading

edgao commented May 30, 2023 •

edited by github-actions bot

Loading

edgao commented May 30, 2023 •

edited by github-actions bot

Loading

cgardens commented May 30, 2023 •

edited by github-actions bot

Loading

cgardens commented May 30, 2023 •

edited by github-actions bot

Loading

cgardens commented May 30, 2023 •

edited by github-actions bot

Loading

cgardens commented May 31, 2023 •

edited by github-actions bot

Loading

cgardens commented May 31, 2023 •

edited by github-actions bot

Loading

cgardens commented May 31, 2023 •

edited by github-actions bot

Loading

cgardens commented May 31, 2023 •

edited by github-actions bot

Loading

cgardens commented May 31, 2023 •

edited by github-actions bot

Loading

cgardens commented May 31, 2023 •

edited by github-actions bot

Loading