Skip to content

Commit

Permalink
Cleanup main entry point and local implementation of spark transforms
Browse files Browse the repository at this point in the history
Signed-off-by: Constantin M Adam <[email protected]>
  • Loading branch information
cmadam committed Nov 15, 2024
1 parent f3c5be0 commit 4941d5b
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
6 changes: 1 addition & 5 deletions transforms/universal/fdedup/spark/Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,7 @@ RUN pip3 install -r requirements.txt
RUN pip install --no-cache-dir -e .

# copy the main() entry point to the image
COPY ./src/signature_calc_spark.py .

# copy some of the samples in
COPY src/signature_calc_transform_spark.py fdedup_transform_spark.py
COPY src/signature_calc_spark.py local/fdedup_local_spark.py
COPY ./src/fdedup_transform_spark.py .

# copy test
COPY test/ test/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,10 @@
import sys

import polars as pl
from data_cleaning_transform import (
document_id_column_cli_param,
duplicate_list_location_cli_param,
)
from data_cleaning_transform_spark import DataCleaningSparkTransformConfiguration
from data_processing.utils import ParamsUtils
from data_processing_spark.runtime.spark import SparkTransformLauncher
Expand Down

0 comments on commit 4941d5b

Please sign in to comment.