def do_db_version():
"""Print database's current migration level."""
- print migration.db_version()
+ print(migration.db_version())
def do_db_sync():
def __call__(self, req):
print ("*" * 40) + " REQUEST ENVIRON"
for key, value in req.environ.items():
- print key, "=", value
+ print(key, "=", value)
print
resp = req.get_response(self.application)
print ("*" * 40) + " RESPONSE HEADERS"
for (key, value) in resp.headers.iteritems():
- print key, "=", value
+ print(key, "=", value)
print
resp.app_iter = self.print_generator(resp.app_iter)
try:
main(url=sql_connection, debug='False', repository=migrate_repo_path)
except migrate.exceptions.DatabaseAlreadyControlledError:
- print 'Database already version controlled.'
+ print('Database already version controlled.')
# License for the specific language governing permissions and limitations
# under the License.
+from __future__ import print_function
+
import gettext
import sys
if __name__ == '__main__':
- print >>sys.stderr, '*******************************************'
- print >>sys.stderr, 'Deprecated: use heat-manage db_sync instead'
- print >>sys.stderr, '*******************************************'
+ print('*******************************************', file=sys.stderr)
+ print('Deprecated: use heat-manage db_sync instead', file=sys.stderr)
+ print('*******************************************', file=sys.stderr)
cfg.CONF(project='heat', prog='heat-engine')
api.configure()
try:
migration.db_sync()
except Exception as exc:
- print >>sys.stderr, str(exc)
+ print(str(exc), file=sys.stderr)
sys.exit(1)
try:
assert entry[2] == body
except AssertionError:
- print entry[2]
- print "!="
- print body
+ print(entry[2])
+ print("!=")
+ print(body)
raise
self.client.callstack = []
stdout, stderr = proc.communicate()
if proc.returncode:
- print 'Error executing %s:\n %s %s ' % (bin, stdout, stderr)
+ print('Error executing %s:\n %s %s ' % (bin, stdout, stderr))
raise subprocess.CalledProcessError(proc.returncode, bin)
yield
def do_step(self, step_num, *args, **kwargs):
- print self, step_num
+ print(self, step_num)
class PollingTaskGroupTest(mox.MoxTestBase):