[2019-01-16T01:04:24.849210Z] def test_getAfwSchemaWithExtras(self):
|
[2019-01-16T01:04:24.849214Z] """Test for getAfwSchema method using extra afw schemas.
|
[2019-01-16T01:04:24.849218Z]
|
[2019-01-16T01:04:24.849221Z] Same as above but use non-default afw schemas, this adds few extra
|
[2019-01-16T01:04:24.849226Z] columns to the table schema
|
[2019-01-16T01:04:24.849230Z] """
|
[2019-01-16T01:04:24.849233Z] engine = create_engine('sqlite://')
|
[2019-01-16T01:04:24.849236Z]
|
[2019-01-16T01:04:24.849240Z] # create standard (baseline) schema, but use afw column map
|
[2019-01-16T01:04:24.849243Z] afw_schemas = dict(DiaObject=make_minimal_dia_object_schema(),
|
[2019-01-16T01:04:24.849246Z] DiaSource=make_minimal_dia_source_schema())
|
[2019-01-16T01:04:24.849250Z] schema = PpdbSchema(engine=engine,
|
[2019-01-16T01:04:24.849253Z] dia_object_index="baseline",
|
[2019-01-16T01:04:24.849256Z] dia_object_nightly=False,
|
[2019-01-16T01:04:24.849260Z] schema_file=_data_file_name("ppdb-schema.yaml"),
|
[2019-01-16T01:04:24.849263Z] column_map=_data_file_name("ppdb-afw-map.yaml"),
|
[2019-01-16T01:04:24.849266Z] afw_schemas=afw_schemas)
|
[2019-01-16T01:04:24.849270Z] schema.makeSchema()
|
[2019-01-16T01:04:24.849274Z]
|
[2019-01-16T01:04:24.849278Z] afw_schema, col_map = schema.getAfwSchema("DiaObject")
|
[2019-01-16T01:04:24.849281Z] self.assertEqual(len(col_map), 94)
|
[2019-01-16T01:04:24.849284Z] self.assertIsInstance(afw_schema, afwTable.Schema)
|
[2019-01-16T01:04:24.849288Z] # no BLOBs in afwTable, so count is lower
|
[2019-01-16T01:04:24.849291Z] self.assertEqual(afw_schema.getFieldCount(), 82)
|
[2019-01-16T01:04:24.849295Z]
|
[2019-01-16T01:04:24.849298Z] afw_schema, col_map = schema.getAfwSchema("DiaSource")
|
[2019-01-16T01:04:24.849301Z] > self.assertEqual(len(col_map), 109)
|
[2019-01-16T01:04:24.849305Z] E AssertionError: 108 != 109
|
Jenkins: https://ci.lsst.codes/blue/organizations/jenkins/stack-os-matrix/detail/stack-os-matrix/29258/pipeline