SciXTEMPLATE package

Subpackages

• SciXTEMPLATE.API package
  • Subpackages
    • SciXTEMPLATE.API.grpc_modules package
      • Submodules
      • SciXTEMPLATE.API.grpc_modules.template_grpc module
      • Module contents
  • Submodules
  • SciXTEMPLATE.API.avro_serializer module
    • AvroSerialHelper
      • AvroSerialHelper.avro_deserializer()
      • AvroSerialHelper.avro_serializer()
  • SciXTEMPLATE.API.template_client module
    • Logging
    • input_parser()
    • output_message()
    • run()
  • SciXTEMPLATE.API.template_server module
    • Listener
      • Listener.get_status_redis()
      • Listener.subscribe()
    • Logging
    • Template
      • Template.initTemplate()
      • Template.monitorTemplate()
      • Template.persistent_connection()
      • Template.session_scope()
    • serve()
  • Module contents
• SciXTEMPLATE.TEMPLATE package
  • Subpackages
    • SciXTEMPLATE.TEMPLATE.base package
      • Module contents
  • Submodules
  • SciXTEMPLATE.TEMPLATE.db module
    • get_TEMPLATE_record()
    • get_job_status_by_job_hash()
    • update_job_status()
    • write_TEMPLATE_record()
    • write_job_status()
    • write_status_redis()
  • SciXTEMPLATE.TEMPLATE.models module
    • Source
      • Source.SYMBOL1
      • Source.SYMBOL2
      • Source.SYMBOL3
      • Source.SYMBOL4
    • Status
      • Status.Error
      • Status.Pending
      • Status.Processing
      • Status.Success
    • TEMPLATE_record
      • TEMPLATE_record.checksum
      • TEMPLATE_record.date
      • TEMPLATE_record.id
      • TEMPLATE_record.s3_key
      • TEMPLATE_record.source
    • gRPC_status
      • gRPC_status.id
      • gRPC_status.job_hash
      • gRPC_status.job_request
      • gRPC_status.status
      • gRPC_status.timestamp
  • SciXTEMPLATE.TEMPLATE.s3_methods module
    • load_s3
      • load_s3.load_s3_providers()
    • s3_methods
      • s3_methods.write_object_s3()
    • s3_provider
  • SciXTEMPLATE.TEMPLATE.template module
    • TEMPLATE_APP
      • TEMPLATE_APP.session_scope()
      • TEMPLATE_APP.template_consumer()
      • TEMPLATE_APP.template_task()
    • init_pipeline()
  • SciXTEMPLATE.TEMPLATE.utils module
    • conf_update_from_env()
    • from_object()
    • get_schema()
    • load_config()
    • load_module()
  • Module contents

Submodules

SciXTEMPLATE.config module

SciXTEMPLATE.run module

Module contents