def create_transactions_table(session):
 create_table = '\n    CREATE TABLE IF NOT EXISTS transactions (\n      txid_hash blob,\n      operation tinyint,\n      namespace text,\n      path blob,\n      start_time timestamp,\n      is_xg boolean,\n      in_progress blob,\n      entity blob,\n      task blob,\n      PRIMARY KEY (txid_hash, operation, namespace, path)\n    )\n  '
 statement = SimpleStatement(create_table, retry_policy=NO_RETRIES)
 try:
  session.execute(statement)
 except cassandra.OperationTimedOut:
  logging.warning('Encountered an operation timeout while creating transactions table. Waiting 1 minute for schema to settle.')
  time.sleep(60)
  raise

def create_transactions_table ( session ) : create_table = '\n    CREATE TABLE IF NOT EXISTS transactions (\n      txid_hash blob,\n      operation tinyint,\n      namespace text,\n      path blob,\n      start_time timestamp,\n      is_xg boolean,\n      in_progress blob,\n      entity blob,\n      task blob,\n      PRIMARY KEY (txid_hash, operation, namespace, path)\n    )\n  ' statement = SimpleStatement ( create_table , retry_policy = NO_RETRIES ) try : session . execute ( statement ) except cassandra . OperationTimedOut : logging . warning ( 'Encountered an operation timeout while creating transactions table. Waiting 1 minute for schema to settle.' ) time . sleep ( 60 ) raise
create the table used for storing transaction metadata .