-
Notifications
You must be signed in to change notification settings - Fork 0
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
Class bases ETL for Glide, Emdat. #208
Conversation
d115cb1
to
280a069
Compare
37d6cc7
to
1dab3b0
Compare
e06c951
to
ecd874b
Compare
ecd874b
to
15f9e69
Compare
2757a22
to
6a0945f
Compare
@@ -11,4 +11,4 @@ class Command(BaseCommand): | |||
help = "Import data from EM-DAT" | |||
|
|||
def handle(self, *args, **options): | |||
ext_and_transform_emdat_historical_data.delay() | |||
ext_and_transform_emdat_historical_data() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why did we remove delay?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We removed delay here as it has chain(EMDATExtraction.task.s(QUERY, variables), EMDATTransformHandler.task.s()).apply_async()
running internally which is asynchronous.
bb83195
to
bf5fb82
Compare
f6b8170
to
9bb07c5
Compare
- Add start date from env variable for gdacs, glide, emdat, ifrc - Load pystac item with status equals to pending. - Set conrtab for idu historical data. - Fix glide url - Send data into pdc transformer in a temp file.
9bc7f0f
to
ae8ed22
Compare
- Re-format graphql query - Define query variables for emdat and glide - Simplify logic for glide task
Addresses
Depends on
Changes
This PR doesn't introduce any:
print
This PR contains valid: