agent.py 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. from sqlalchemy import create_engine, Column, Integer, String, MetaData,DateTime,Text,ForeignKey
  2. from sqlalchemy.ext.declarative import declarative_base
  3. from sqlalchemy.orm import sessionmaker
  4. from agent.db.database import Base
  5. class Job(Base):
  6. __tablename__ = 'jobs'
  7. id = Column(Integer, primary_key=True)
  8. job_category = Column(String(64), nullable=False)
  9. job_name = Column(String(64))
  10. job_details = Column(Text, nullable=False)
  11. job_creator = Column(String(64), nullable=False)
  12. job_logs = Column(Text, nullable=True)
  13. job_files = Column(String(300), nullable=True)
  14. executor = Column(String(64), nullable=True)
  15. created = Column(DateTime, nullable=False)
  16. updated = Column(DateTime, nullable=False)
  17. status = Column(Integer, default=0)
  18. class JobQueue(Base):
  19. __tablename__ = 'job_queues'
  20. id = Column(Integer, primary_key=True)
  21. queue_category = Column(String(64), nullable=False)
  22. queue_name = Column(String(64), nullable=False)
  23. status = Column(Integer, default=0)
  24. class QueueJob(Base):
  25. __tablename__ = 'queue_job'
  26. id = Column(Integer, primary_key=True)
  27. queue_id = Column(Integer, ForeignKey('job_queues.id'), nullable=False)
  28. job_id = Column(Integer, ForeignKey('jobs.id'), nullable=False)