in demo_deployment/firestore_crud.py [0:0]
def main(args, loglevel):
logging.basicConfig(format="%(levelname)s: %(message)s", level=loglevel)
db = firestore.Client(project=args.gcp_project, database=DEFAULT_DATABASE_NAME)
if hasattr(args, 'workflow_properties'):
print(args.workflow_properties)
#workflow_props = json.loads(args.workflow_properties)
workflow_props = args.workflow_properties
if args.operation_type in('CREATE','UPDATE'):
data = {
"workflows_name": args.workflow_name,
"crond_expression": args.crond_expression,
"time_zone": args.time_zone,
"date_format": args.date_format,
"workflow_status": args.workflow_status,
"workflow_properties": workflow_props
}
if args.operation_type == 'CREATE':
create_doc(db, data)
if args.operation_type == 'UPDATE':
update_doc(db,data)
if args.operation_type == 'DELETE':
delete_doc(db)