# Setup logging
log = logging.getLogger("pbs.jobs")
+JobPackage = sqlalchemy.Table(
+ "job_packages", database.Base.metadata,
+
+ # Job
+ Column("job_id", ForeignKey("jobs.id"), nullable=False),
+
+ # Package
+ Column("pkg_id", ForeignKey("packages.id"), nullable=False),
+)
+
class Jobs(base.Object):
connections = {}
# Binary Packages
- JobPackages = sqlalchemy.Table(
- "job_packages", database.Base.metadata,
-
- # Job
- Column("job_id", ForeignKey("jobs.id")),
-
- # Package
- Column("pkg_id", ForeignKey("packages.id")),
- )
-
- packages = sqlalchemy.orm.relationship("Package", secondary=JobPackages, lazy="selectin")
+ packages = sqlalchemy.orm.relationship("Package", secondary=JobPackage, lazy="selectin")
async def _import_packages(self, uploads):
"""