+configuration = Table(\r
+ "configuration",\r
+ metadata,\r
+ Column("updatetime", DateTime),\r
+ Column("createtime", DateTime),\r
+\r
+ Column("configurationId", String(255), primary_key=True),\r
+ Column("conftype", String(255)),\r
+ Column("callback", String(255)),\r
+ Column("status", String(255)),\r
+ Column("comments", String(255)),\r
+)\r
+\r
+\r
+@retry((exc.IntegrityError), tries=3, delay=2)\r
+def wait_for_metadata_ready(engine):\r
+ # wait for mapper ready\r
+ metadata.create_all(engine, checkfirst=True)\r
+ logger.info("metadata is ready")\r
+\r