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

4290 prefect pipeline #266

Open
wants to merge 29 commits into
base: master
Choose a base branch
from
Open

4290 prefect pipeline #266

wants to merge 29 commits into from

Conversation

craigrose
Copy link
Contributor

These modify aodncore to allow for running of pipelines with Prefect and S3 buckets. The changes should not affect existing pipeline operations.

@codecov
Copy link

codecov bot commented Sep 9, 2022

Codecov Report

Patch coverage: 30.20% and project coverage change: -1.57 ⚠️

Comparison is base (51baffe) 91.96% compared to head (bb3658a) 90.39%.

❗ Current head bb3658a differs from pull request most recent head 1bf123b. Consider uploading reports for the commit 1bf123b to get more accurate results

Additional details and impacted files
@@            Coverage Diff             @@
##           master     #266      +/-   ##
==========================================
- Coverage   91.96%   90.39%   -1.57%     
==========================================
  Files          39       41       +2     
  Lines        4082     4176      +94     
  Branches      590      485     -105     
==========================================
+ Hits         3754     3775      +21     
- Misses        265      334      +69     
- Partials       63       67       +4     
Impacted Files Coverage Δ
aodncore/pipeline/prefecthandlerbase.py 0.00% <0.00%> (ø)
aodncore/pipeline/schema.py 100.00% <ø> (ø)
aodncore/pipeline/steps/harvest.py 94.87% <23.07%> (-3.13%) ⬇️
aodncore/util/s3_util.py 46.66% <46.66%> (ø)
aodncore/pipeline/steps/resolve.py 94.71% <60.00%> (-0.92%) ⬇️
aodncore/util/__init__.py 100.00% <100.00%> (ø)
aodncore/util/fileops.py 82.77% <100.00%> (-1.39%) ⬇️

... and 1 file with indirect coverage changes

☔ View full report in Codecov by Sentry.
📢 Do you have feedback about the report comment? Let us know in this issue.

Copy link
Contributor

@mhidas mhidas left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Just adding my 2c's worth while I look at this.

@@ -0,0 +1,64 @@
from urllib.parse import urlparse
import boto3
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Some functionality for handling objects on S3 is already implemented as an S3StorageBroker class that suports query, download, upload and delete operations. Could that be reused instead of duplicating the functionality here?

""" Override HandlerBase"""

try:
self._file_checksum = self.etag
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I can't see where this etag attribute is set?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants