Skip to content

Commit

Permalink
FIX: replace open_dataarray with UnitsDataArray.open() (see #334)
Browse files Browse the repository at this point in the history
  • Loading branch information
mlshapiro committed Nov 13, 2019
1 parent b84e053 commit 06c9ede
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions podpac/core/managers/aws.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
import traitlets as tl
import numpy as np

from podpac.core.units import open_dataarray
from podpac.core.units import UnitsDataArray
from podpac.core.settings import settings
from podpac.core.node import COMMON_NODE_DOC, Node
from podpac.core.utils import common_doc, JSONEncoder
Expand Down Expand Up @@ -1227,7 +1227,7 @@ def _eval_invoke(self, coordinates, output=None):

# After waiting, load the pickle file like this:
payload = response["Payload"].read()
self._output = open_dataarray(payload)
self._output = UnitsDataArray.open(payload)
return self._output

def _eval_s3(self, coordinates, output=None):
Expand Down Expand Up @@ -1290,7 +1290,7 @@ def _eval_s3(self, coordinates, output=None):
_log.debug("Received response from lambda function")
response = s3.get_object(Key=filename, Bucket=self.function_s3_bucket)
body = response["Body"].read()
self._output = open_dataarray(body)
self._output = UnitsDataArray.open(body)
return self._output

def _eval_api(self, coordinates, output=None):
Expand Down

0 comments on commit 06c9ede

Please sign in to comment.