Update DeckHand Operator

The validation endpoint should take the form of

/api/v1.0/revisions/{revision_id}/validations

This is different from what is currently defined
in the DeckHand Operator.  This P.S. is meant to
correct the endpoint and add more logging output.

Change-Id: I5be585df6fac96b9a27758cbb5dd90c5be163098
This commit is contained in:
Anthony Lin 2017-10-19 22:46:12 +00:00
parent 2168b3f00b
commit 491a8571b6
1 changed files with 5 additions and 0 deletions

View File

@ -124,6 +124,8 @@ class DeckhandOperator(BaseOperator):
except requests.exceptions.RequestException as e:
raise AirflowException(e)
logging.info(revisions)
# Print the number of revisions that is currently available on
# DeckHand
logging.info("The number of revisions is %s", revisions['count'])
@ -153,6 +155,7 @@ class DeckhandOperator(BaseOperator):
# Form Validation Endpoint
validation_endpoint = os.path.join(context['svc_endpoint'],
'revisions',
str(context['revision_id']),
'validations')
logging.info(validation_endpoint)
@ -166,6 +169,8 @@ class DeckhandOperator(BaseOperator):
except requests.exceptions.RequestException as e:
raise AirflowException(e)
logging.info(retrieved_list)
# Initialize Validation Status
validation_status = True