def create_table(dataset_id, table_id):
    print('Creating table {0}.{1}'.format(dataset_id, table_id))
    project_id = get_project_identifier()
    schema = BigQueryCohortSupport.get_schema()
    dataset_args = {'projectId': project_id, 'datasetId': dataset_id}
    table_ref = {'tableId': table_id, 'projectId': project_id, 'datasetId': dataset_id}
    table = {'tableReference': table_ref, 'schema': {'fields': schema}}
    service = authorize_and_get_bq_service()
    table = service.tables().insert(body=table, **dataset_args).execute()
    return table
def create_table(dataset_id, table_id):
    print('Creating table {0}.{1}'.format(dataset_id, table_id))
    project_id = get_project_identifier()
    schema = BigQueryCohortSupport.get_schema()
    dataset_args = {'projectId': project_id, 'datasetId': dataset_id}
    table_ref = {'tableId': table_id, 'projectId': project_id, 'datasetId': dataset_id}
    table = {'tableReference': table_ref, 'schema': {'fields': schema}}
    service = authorize_and_get_bq_service()
    table = service.tables().insert(body=table, **dataset_args).execute()
    return table