Skip to content

Commit

Permalink
nasa#464 Suppressed critical bug by creating necessary arguements
Browse files Browse the repository at this point in the history
  • Loading branch information
goldpanth3r committed Sep 23, 2023
1 parent ce82acd commit 3237f84
Showing 1 changed file with 17 additions and 8 deletions.
25 changes: 17 additions & 8 deletions workload/locustfile-prod.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
from time import time
from locust import task, tag
import urllib.parse
from harmony.common import BaseHarmonyUser
Expand Down Expand Up @@ -72,6 +73,7 @@ def harmony_gdal_adapter(self):
@task(2)
def podaac_l2ss_async(self):
collection = 'C1940473819-POCLOUD'
name='PODAAC L2SS Async'
variable = 'all'
params = {
'maxResults': 2,
Expand All @@ -80,20 +82,22 @@ def podaac_l2ss_async(self):
'lat(-80:80)'
]
}
start_time = time()
response = self.client.get(
self.coverages_root.format(
collection=collection,
variable=variable
),
params=params,
name='PODAAC L2SS Async'
name=name
)
self.wait_for_job_completion(response)
self.wait_for_job_completion(response, name, start_time)

@tag('podaac-l2ss', 'bbox', 'async', 'netcdf4', 'temporal', 'agu')
@task(1)
def podaac_l2ss_async_spatial_temporal(self):
collection = 'C1940475563-POCLOUD'
name = 'PODAAC L2SS Async Spatial and Temporal'
variable = 'all'
params = {
'subset': [
Expand All @@ -102,50 +106,55 @@ def podaac_l2ss_async_spatial_temporal(self):
'time("2019-06-22T00:00:00Z":"2019-06-22T23:59:59Z")'
]
}
start_time = time()
response = self.client.get(
self.coverages_root.format(
collection=collection,
variable=variable
),
params=params,
name='PODAAC L2SS Async Spatial and Temporal'
name=name
)
self.wait_for_job_completion(response)
self.wait_for_job_completion(response, name, start_time)

@tag('netcdf-to-zarr', 'async', 'zarr', 'agu')
@task(1)
def netcdf_to_zarr_single_granule(self):
collection = 'C1938032626-POCLOUD'
name = 'NetCDF to Zarr single granule'
variable = 'all'
params = {
'maxResults': 1
}
start_time = time()
response = self.client.get(
self.coverages_root.format(
collection=collection,
variable=variable
),
params=params,
name='NetCDF to Zarr single granule'
name=name
)
self.wait_for_job_completion(response)
self.wait_for_job_completion(response, name, start_time)

@tag('netcdf-to-zarr', 'async', 'zarr', 'agu', 'temporal')
@task(1)
def netcdf_to_zarr_temporal(self):
collection = 'C1940468263-POCLOUD'
name = 'NetCDF to Zarr temporal subset'
variable = 'all'
params = {
'subset': [
'time("2020-01-01T00:00:00.000Z":"2020-01-02T00:00:00.000Z")'
]
}
start_time = time()
response = self.client.get(
self.coverages_root.format(
collection=collection,
variable=variable
),
params=params,
name='NetCDF to Zarr temporal subset'
name=name
)
self.wait_for_job_completion(response)
self.wait_for_job_completion(response, name, start_time)

0 comments on commit 3237f84

Please sign in to comment.