[pipes-java] move Java Pipes to implementations/java

dagster-io · Jan 15, 2025 · f6bb095 · f6bb095
1 parent b9675a6
commit f6bb095
Show file tree

Hide file tree

Showing 75 changed files with 9 additions and 9 deletions.
diff --git a/.github/workflows/libraries-pipes-java.yml b/.github/workflows/libraries-pipes-java.yml
@@ -10,7 +10,7 @@ on:
 
 defaults:
   run:
-    working-directory: ./libraries/pipes/implementations/java/dagster-pipes-java/
+    working-directory: ./libraries/pipes/implementations/java/
 
 jobs:
   integration-tests:

diff --git a/...ations/java/dagster-pipes-java/.gitignore → ...ies/pipes/implementations/java/.gitignore b/...ations/java/dagster-pipes-java/.gitignore → ...ies/pipes/implementations/java/.gitignore
diff --git a/...tations/java/dagster-pipes-java/README.md → ...ries/pipes/implementations/java/README.md b/...tations/java/dagster-pipes-java/README.md → ...ries/pipes/implementations/java/README.md
diff --git a/...ions/java/dagster-pipes-java/build.gradle → ...s/pipes/implementations/java/build.gradle b/...ions/java/dagster-pipes-java/build.gradle → ...s/pipes/implementations/java/build.gradle
diff --git a/...dagster-pipes-java/config/pmd-ruleset.xml → ...plementations/java/config/pmd-ruleset.xml b/...dagster-pipes-java/config/pmd-ruleset.xml → ...plementations/java/config/pmd-ruleset.xml
diff --git a/...-pipes-java/examples/local/definitions.py → ...ations/java/examples/local/definitions.py b/...-pipes-java/examples/local/definitions.py → ...ations/java/examples/local/definitions.py
diff --git a/...es-java/gradle/wrapper/gradle-wrapper.jar → ...ns/java/gradle/wrapper/gradle-wrapper.jar b/...es-java/gradle/wrapper/gradle-wrapper.jar → ...ns/java/gradle/wrapper/gradle-wrapper.jar
diff --git a/.../gradle/wrapper/gradle-wrapper.properties → .../gradle/wrapper/gradle-wrapper.properties b/.../gradle/wrapper/gradle-wrapper.properties → .../gradle/wrapper/gradle-wrapper.properties
diff --git a/...entations/java/dagster-pipes-java/gradlew → libraries/pipes/implementations/java/gradlew b/...entations/java/dagster-pipes-java/gradlew → libraries/pipes/implementations/java/gradlew
diff --git a/...tions/java/dagster-pipes-java/gradlew.bat → ...es/pipes/implementations/java/gradlew.bat b/...tions/java/dagster-pipes-java/gradlew.bat → ...es/pipes/implementations/java/gradlew.bat
diff --git a/...jsonschema/pipes/PipesContext.schema.json → ...jsonschema/pipes/PipesContext.schema.json b/...jsonschema/pipes/PipesContext.schema.json → ...jsonschema/pipes/PipesContext.schema.json
diff --git a/...onschema/pipes/PipesException.schema.json → ...onschema/pipes/PipesException.schema.json b/...onschema/pipes/PipesException.schema.json → ...onschema/pipes/PipesException.schema.json
diff --git a/...ava/jsonschema/pipes/PipesLog.schema.json → ...ava/jsonschema/pipes/PipesLog.schema.json b/...ava/jsonschema/pipes/PipesLog.schema.json → ...ava/jsonschema/pipes/PipesLog.schema.json
diff --git a/...jsonschema/pipes/PipesMessage.schema.json → ...jsonschema/pipes/PipesMessage.schema.json b/...jsonschema/pipes/PipesMessage.schema.json → ...jsonschema/pipes/PipesMessage.schema.json
diff --git a/...hema/pipes/PipesMetadataValue.schema.json → ...hema/pipes/PipesMetadataValue.schema.json b/...hema/pipes/PipesMetadataValue.schema.json → ...hema/pipes/PipesMetadataValue.schema.json
diff --git a/...ations/java/dagster-pipes-java/pipes.toml → ...ies/pipes/implementations/java/pipes.toml b/...ations/java/dagster-pipes-java/pipes.toml → ...ies/pipes/implementations/java/pipes.toml
diff --git a/...ns/java/dagster-pipes-java/pyproject.toml → ...pipes/implementations/java/pyproject.toml b/...ns/java/dagster-pipes-java/pyproject.toml → ...pipes/implementations/java/pyproject.toml
@@ -19,7 +19,7 @@ dev-dependencies = [
 ]
 
 [tool.uv.sources]
-dagster-pipes-tests = { path = "../../../tests/dagster-pipes-tests", editable = true }
+dagster-pipes-tests = { path = "../../tests/dagster-pipes-tests", editable = true }
 
 [tool.pytest.ini_options]
 addopts = "-s "

diff --git a/...ions/java/dagster-pipes-java/quicktype.sh → ...s/pipes/implementations/java/quicktype.sh b/...ions/java/dagster-pipes-java/quicktype.sh → ...s/pipes/implementations/java/quicktype.sh
diff --git a/...s/java/dagster-pipes-java/settings.gradle → ...ipes/implementations/java/settings.gradle b/...s/java/dagster-pipes-java/settings.gradle → ...ipes/implementations/java/settings.gradle
diff --git a/...ain/java/pipes/DagsterPipesException.java → ...ain/java/pipes/DagsterPipesException.java b/...ain/java/pipes/DagsterPipesException.java → ...ain/java/pipes/DagsterPipesException.java
diff --git a/...ava/src/main/java/pipes/PipesContext.java → ...ava/src/main/java/pipes/PipesContext.java b/...ava/src/main/java/pipes/PipesContext.java → ...ava/src/main/java/pipes/PipesContext.java
diff --git a/...ava/src/main/java/pipes/PipesSession.java → ...ava/src/main/java/pipes/PipesSession.java b/...ava/src/main/java/pipes/PipesSession.java → ...ava/src/main/java/pipes/PipesSession.java
diff --git a/...src/main/java/pipes/ThrowingConsumer.java → ...src/main/java/pipes/ThrowingConsumer.java b/...src/main/java/pipes/ThrowingConsumer.java → ...src/main/java/pipes/ThrowingConsumer.java
diff --git a/...a/pipes/data/PipesAssetCheckSeverity.java → ...a/pipes/data/PipesAssetCheckSeverity.java b/...a/pipes/data/PipesAssetCheckSeverity.java → ...a/pipes/data/PipesAssetCheckSeverity.java
diff --git a/.../main/java/pipes/data/PipesConstants.java → .../main/java/pipes/data/PipesConstants.java b/.../main/java/pipes/data/PipesConstants.java → .../main/java/pipes/data/PipesConstants.java
diff --git a/...ain/java/pipes/data/PipesContextData.java → ...ain/java/pipes/data/PipesContextData.java b/...ain/java/pipes/data/PipesContextData.java → ...ain/java/pipes/data/PipesContextData.java
diff --git a/.../main/java/pipes/data/PipesException.java → .../main/java/pipes/data/PipesException.java b/.../main/java/pipes/data/PipesException.java → .../main/java/pipes/data/PipesException.java
diff --git a/...c/main/java/pipes/data/PipesMetadata.java → ...c/main/java/pipes/data/PipesMetadata.java b/...c/main/java/pipes/data/PipesMetadata.java → ...c/main/java/pipes/data/PipesMetadata.java
diff --git a/...ava/pipes/loaders/PipesContextLoader.java → ...ava/pipes/loaders/PipesContextLoader.java b/...ava/pipes/loaders/PipesContextLoader.java → ...ava/pipes/loaders/PipesContextLoader.java
diff --git a/...es/loaders/PipesDefaultContextLoader.java → ...es/loaders/PipesDefaultContextLoader.java b/...es/loaders/PipesDefaultContextLoader.java → ...es/loaders/PipesDefaultContextLoader.java
diff --git a/...ipes/loaders/PipesEnvVarParamsLoader.java → ...ipes/loaders/PipesEnvVarParamsLoader.java b/...ipes/loaders/PipesEnvVarParamsLoader.java → ...ipes/loaders/PipesEnvVarParamsLoader.java
diff --git a/...pes/loaders/PipesMappingParamsLoader.java → ...pes/loaders/PipesMappingParamsLoader.java b/...pes/loaders/PipesMappingParamsLoader.java → ...pes/loaders/PipesMappingParamsLoader.java
diff --git a/...java/pipes/loaders/PipesParamsLoader.java → ...java/pipes/loaders/PipesParamsLoader.java b/...java/pipes/loaders/PipesParamsLoader.java → ...java/pipes/loaders/PipesParamsLoader.java
diff --git a/...a/pipes/loaders/PipesS3ContextLoader.java → ...a/pipes/loaders/PipesS3ContextLoader.java b/...a/pipes/loaders/PipesS3ContextLoader.java → ...a/pipes/loaders/PipesS3ContextLoader.java
diff --git a/...main/java/pipes/logger/PipesLogLevel.java → ...main/java/pipes/logger/PipesLogLevel.java b/...main/java/pipes/logger/PipesLogLevel.java → ...main/java/pipes/logger/PipesLogLevel.java
diff --git a/...c/main/java/pipes/logger/PipesLogger.java → ...c/main/java/pipes/logger/PipesLogger.java b/...c/main/java/pipes/logger/PipesLogger.java → ...c/main/java/pipes/logger/PipesLogger.java
diff --git a/...va/src/main/java/pipes/utils/Example.java → ...va/src/main/java/pipes/utils/Example.java b/...va/src/main/java/pipes/utils/Example.java → ...va/src/main/java/pipes/utils/Example.java
diff --git a/...ain/java/pipes/utils/MetadataBuilder.java → ...ain/java/pipes/utils/MetadataBuilder.java b/...ain/java/pipes/utils/MetadataBuilder.java → ...ain/java/pipes/utils/MetadataBuilder.java
diff --git a/...src/main/java/pipes/utils/PipesUtils.java → ...src/main/java/pipes/utils/PipesUtils.java b/...src/main/java/pipes/utils/PipesUtils.java → ...src/main/java/pipes/utils/PipesUtils.java
diff --git a/.../writers/PipesBlobStoreMessageWriter.java → .../writers/PipesBlobStoreMessageWriter.java b/.../writers/PipesBlobStoreMessageWriter.java → .../writers/PipesBlobStoreMessageWriter.java
diff --git a/...s/PipesBlobStoreMessageWriterChannel.java → ...s/PipesBlobStoreMessageWriterChannel.java b/...s/PipesBlobStoreMessageWriterChannel.java → ...s/PipesBlobStoreMessageWriterChannel.java
diff --git a/...esBufferedStreamMessageWriterChannel.java → ...esBufferedStreamMessageWriterChannel.java b/...esBufferedStreamMessageWriterChannel.java → ...esBufferedStreamMessageWriterChannel.java
diff --git a/...es/writers/PipesDefaultMessageWriter.java → ...es/writers/PipesDefaultMessageWriter.java b/...es/writers/PipesDefaultMessageWriter.java → ...es/writers/PipesDefaultMessageWriter.java
diff --git a/.../main/java/pipes/writers/PipesExtras.java → .../main/java/pipes/writers/PipesExtras.java b/.../main/java/pipes/writers/PipesExtras.java → .../main/java/pipes/writers/PipesExtras.java
diff --git a/...riters/PipesFileMessageWriterChannel.java → ...riters/PipesFileMessageWriterChannel.java b/...riters/PipesFileMessageWriterChannel.java → ...riters/PipesFileMessageWriterChannel.java
diff --git a/...main/java/pipes/writers/PipesMessage.java → ...main/java/pipes/writers/PipesMessage.java b/...main/java/pipes/writers/PipesMessage.java → ...main/java/pipes/writers/PipesMessage.java
diff --git a/...ava/pipes/writers/PipesMessageWriter.java → ...ava/pipes/writers/PipesMessageWriter.java b/...ava/pipes/writers/PipesMessageWriter.java → ...ava/pipes/writers/PipesMessageWriter.java
diff --git a/...es/writers/PipesMessageWriterChannel.java → ...es/writers/PipesMessageWriterChannel.java b/...es/writers/PipesMessageWriterChannel.java → ...es/writers/PipesMessageWriterChannel.java
diff --git a/...a/pipes/writers/PipesS3MessageWriter.java → ...a/pipes/writers/PipesS3MessageWriter.java b/...a/pipes/writers/PipesS3MessageWriter.java → ...a/pipes/writers/PipesS3MessageWriter.java
diff --git a/.../writers/PipesS3MessageWriterChannel.java → .../writers/PipesS3MessageWriterChannel.java b/.../writers/PipesS3MessageWriterChannel.java → .../writers/PipesS3MessageWriterChannel.java
diff --git a/...ters/PipesStreamMessageWriterChannel.java → ...ters/PipesStreamMessageWriterChannel.java b/...ters/PipesStreamMessageWriterChannel.java → ...ters/PipesStreamMessageWriterChannel.java
diff --git a/...s-java/src/main/java/types/Converter.java → ...s/java/src/main/java/types/Converter.java b/...s-java/src/main/java/types/Converter.java → ...s/java/src/main/java/types/Converter.java
diff --git a/...ipes-java/src/main/java/types/Method.java → ...ions/java/src/main/java/types/Method.java b/...ipes-java/src/main/java/types/Method.java → ...ions/java/src/main/java/types/Method.java
diff --git a/...rc/main/java/types/PartitionKeyRange.java → ...rc/main/java/types/PartitionKeyRange.java b/...rc/main/java/types/PartitionKeyRange.java → ...rc/main/java/types/PartitionKeyRange.java
diff --git a/.../main/java/types/PartitionTimeWindow.java → .../main/java/types/PartitionTimeWindow.java b/.../main/java/types/PartitionTimeWindow.java → .../main/java/types/PartitionTimeWindow.java
diff --git a/...ava/src/main/java/types/PipesContext.java → ...ava/src/main/java/types/PipesContext.java b/...ava/src/main/java/types/PipesContext.java → ...ava/src/main/java/types/PipesContext.java
diff --git a/...es-java/src/main/java/types/PipesLog.java → ...ns/java/src/main/java/types/PipesLog.java b/...es-java/src/main/java/types/PipesLog.java → ...ns/java/src/main/java/types/PipesLog.java
diff --git a/...ava/src/main/java/types/PipesMessage.java → ...ava/src/main/java/types/PipesMessage.java b/...ava/src/main/java/types/PipesMessage.java → ...ava/src/main/java/types/PipesMessage.java
diff --git a/...c/main/java/types/PipesMetadataValue.java → ...c/main/java/types/PipesMetadataValue.java b/...c/main/java/types/PipesMetadataValue.java → ...c/main/java/types/PipesMetadataValue.java
diff --git a/...main/java/types/ProvenanceByAssetKey.java → ...main/java/types/ProvenanceByAssetKey.java b/...main/java/types/ProvenanceByAssetKey.java → ...main/java/types/ProvenanceByAssetKey.java
diff --git a/...es-java/src/main/java/types/RawValue.java → ...ns/java/src/main/java/types/RawValue.java b/...es-java/src/main/java/types/RawValue.java → ...ns/java/src/main/java/types/RawValue.java
diff --git a/...-pipes-java/src/main/java/types/Type.java → ...ations/java/src/main/java/types/Type.java b/...-pipes-java/src/main/java/types/Type.java → ...ations/java/src/main/java/types/Type.java
diff --git a/...-java/src/test/java/pipes/DataLoader.java → .../java/src/test/java/pipes/DataLoader.java b/...-java/src/test/java/pipes/DataLoader.java → .../java/src/test/java/pipes/DataLoader.java
diff --git a/...es-java/src/test/java/pipes/MainTest.java → ...ns/java/src/test/java/pipes/MainTest.java b/...es-java/src/test/java/pipes/MainTest.java → ...ns/java/src/test/java/pipes/MainTest.java
diff --git a/...-java/src/test/java/pipes/PipesTests.java → .../java/src/test/java/pipes/PipesTests.java b/...-java/src/test/java/pipes/PipesTests.java → .../java/src/test/java/pipes/PipesTests.java
diff --git a/...s-java/src/test/java/pipes/TestUtils.java → ...s/java/src/test/java/pipes/TestUtils.java b/...s-java/src/test/java/pipes/TestUtils.java → ...s/java/src/test/java/pipes/TestUtils.java
diff --git a/...t/java/pipes/data/PipesExceptionTest.java → ...t/java/pipes/data/PipesExceptionTest.java b/...t/java/pipes/data/PipesExceptionTest.java → ...t/java/pipes/data/PipesExceptionTest.java
diff --git a/...oaders/PipesDefaultContextLoaderTest.java → ...oaders/PipesDefaultContextLoaderTest.java b/...oaders/PipesDefaultContextLoaderTest.java → ...oaders/PipesDefaultContextLoaderTest.java
diff --git a/...java/pipes/utils/MetadataBuilderTest.java → ...java/pipes/utils/MetadataBuilderTest.java b/...java/pipes/utils/MetadataBuilderTest.java → ...java/pipes/utils/MetadataBuilderTest.java
diff --git a/...riters/PipesMessageWriterChannelTest.java → ...riters/PipesMessageWriterChannelTest.java b/...riters/PipesMessageWriterChannelTest.java → ...riters/PipesMessageWriterChannelTest.java
diff --git a/...pes-java/src/test/resources/realJson.json → ...ons/java/src/test/resources/realJson.json b/...pes-java/src/test/resources/realJson.json → ...ons/java/src/test/resources/realJson.json
diff --git a/...java/dagster-pipes-java/tests/__init__.py → ...es/implementations/java/tests/__init__.py b/...java/dagster-pipes-java/tests/__init__.py → ...es/implementations/java/tests/__init__.py
diff --git a/...java/dagster-pipes-java/tests/conftest.py → ...es/implementations/java/tests/conftest.py b/...java/dagster-pipes-java/tests/conftest.py → ...es/implementations/java/tests/conftest.py
diff --git a/...va/dagster-pipes-java/tests/test_pipes.py → .../implementations/java/tests/test_pipes.py b/...va/dagster-pipes-java/tests/test_pipes.py → .../implementations/java/tests/test_pipes.py
diff --git a/...entations/java/dagster-pipes-java/uv.lock → libraries/pipes/implementations/java/uv.lock b/...entations/java/dagster-pipes-java/uv.lock → libraries/pipes/implementations/java/uv.lock