From 491a8571b6e1209cc0cf6111aef90ca0b31fbbab Mon Sep 17 00:00:00 2001 From: Anthony Lin Date: Thu, 19 Oct 2017 22:46:12 +0000 Subject: [PATCH] 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 --- shipyard_airflow/plugins/deckhand_operator.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/shipyard_airflow/plugins/deckhand_operator.py b/shipyard_airflow/plugins/deckhand_operator.py index bf1449f7..74145477 100644 --- a/shipyard_airflow/plugins/deckhand_operator.py +++ b/shipyard_airflow/plugins/deckhand_operator.py @@ -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