Skip to content

Commit

Permalink
fix pipeline catalog (?)
Browse files Browse the repository at this point in the history
  • Loading branch information
tgrandje committed Dec 20, 2024
1 parent 5d944c8 commit fec26bd
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 17 deletions.
7 changes: 1 addition & 6 deletions argo-pipeline/pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -305,12 +305,7 @@ spec:
mountPath: /mnt
env: *env_parameters

- name: make-catalog
outputs:
parameters:
- name: result
valueFrom:
path: "catalog/result.json"
- name: make-catalogs
container:
image: inseefrlab/cartiflette:latest
command: ["sh", "-c"]
Expand Down
14 changes: 3 additions & 11 deletions argo-pipeline/src/catalog.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,17 +33,9 @@ def main(
fs: S3FileSystem = FS,
):

success = True
try:
make_s3_inventory(
fs=fs, bucket=bucket, path_within_bucket=path_within_bucket
)
except Exception:
success = False

out_path = "catalog/result.json"
with open(out_path, "w", encoding="utf8") as out:
json.dump(success, out)
make_s3_inventory(
fs=fs, bucket=bucket, path_within_bucket=path_within_bucket
)

logger.info("Success!")

Expand Down

0 comments on commit fec26bd

Please sign in to comment.