Import a missing python module
Add comment/readme
Change-Id: Ia841b5226b948297f0c0d4adfca0a1acbadf661c
diff --git a/VERSION b/VERSION
index 2411653..c52db98 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-0.5.2
\ No newline at end of file
+0.5.3
\ No newline at end of file
diff --git a/docker/README.md b/docker/README.md
new file mode 100644
index 0000000..55d7e06
--- /dev/null
+++ b/docker/README.md
@@ -0,0 +1,10 @@
+# Docker image
+
+This directory contains
+- `Dockerfile` to build a docker image for `cord-workflow-airflow` project
+- `docker-compose.yml` for demo setup
+
+DEMO SETUP
+----------
+
+To run, type `docker-compose -f docker-compose.yml up`.
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 6a6dc38..f62365c 100644
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -33,7 +33,7 @@
airflow:
# image: opencord/cord-workflow-airflow
- image: cord-workflow-airflow:0.5.2
+ image: opencord/cord-workflow-airflow:0.5.3
restart: always
depends_on:
- postgres
diff --git a/src/cord_workflow_airflow_extensions/cord_workflow_plugin.py b/src/cord_workflow_airflow_extensions/cord_workflow_plugin.py
index 3a6c83c..6df3b34 100644
--- a/src/cord_workflow_airflow_extensions/cord_workflow_plugin.py
+++ b/src/cord_workflow_airflow_extensions/cord_workflow_plugin.py
@@ -190,7 +190,8 @@
# time.sleep(60)
def execute_callable(self):
- # temporarily comment out this two lines
+ # TODO: NEED TO UNCOMMENT BELOW TWO LINES AFTER XOS_API CONFIGURATION
+ # comment out this two lines
# self.create_model_accessor()
# self.wait_for_ready()
diff --git a/workflow_examples/att-workflow/att_workflow.py b/workflow_examples/att-workflow/att_workflow.py
index 11bfee8..688eb5b 100644
--- a/workflow_examples/att-workflow/att_workflow.py
+++ b/workflow_examples/att-workflow/att_workflow.py
@@ -23,6 +23,7 @@
from airflow.operators.python_operator import PythonOperator
from airflow.sensors.cord_workflow_plugin import CORDEventSensor, CORDModelSensor
from airflow.operators.cord_workflow_plugin import CORDModelOperator
+from xossynchronizer.steps.syncstep import DeferredException
log = logging.getLogger(__name__)
args = {