Skip to content
Snippets Groups Projects
Commit fdb48346 authored by Mattia Mancini's avatar Mattia Mancini
Browse files

Add atdb processing site object

parent 40f720d2
No related branches found
No related tags found
2 merge requests!8update dev-nico to make small changes,!7Add script csv gen
...@@ -6,6 +6,7 @@ from django.contrib.postgres.fields import ArrayField ...@@ -6,6 +6,7 @@ from django.contrib.postgres.fields import ArrayField
from celery.result import AsyncResult from celery.result import AsyncResult
from ldvspec.celery import app as spec_app from ldvspec.celery import app as spec_app
class DataLocation(models.Model): class DataLocation(models.Model):
name = models.CharField(max_length=50, primary_key=True) name = models.CharField(max_length=50, primary_key=True)
uri = models.CharField(max_length=200) uri = models.CharField(max_length=200)
...@@ -79,6 +80,11 @@ class DataProductFilter(models.Model): ...@@ -79,6 +80,11 @@ class DataProductFilter(models.Model):
lookup_type = models.CharField(max_length=100) lookup_type = models.CharField(max_length=100)
class ATDBProcessingSite(models.Model):
name = models.CharField(primary_key=True)
url = models.URLField()
class WorkSpecification(models.Model): class WorkSpecification(models.Model):
created_on = models.DateTimeField(auto_now_add=True) created_on = models.DateTimeField(auto_now_add=True)
created_by = models.ForeignKey(User, on_delete=models.DO_NOTHING, null=True) created_by = models.ForeignKey(User, on_delete=models.DO_NOTHING, null=True)
...@@ -88,10 +94,10 @@ class WorkSpecification(models.Model): ...@@ -88,10 +94,10 @@ class WorkSpecification(models.Model):
is_ready = models.BooleanField(default=False) is_ready = models.BooleanField(default=False)
is_defined = models.BooleanField(default=False) is_defined = models.BooleanField(default=False)
async_task_result = models.CharField(max_length=100, null=True) async_task_result = models.CharField(max_length=100, null=True)
processing_site = models.ForeignKey(ATDBProcessingSite, null=True, on_delete=models.DO_NOTHING)
def save(self, force_insert=False, force_update=False, using=None, def save(self, force_insert=False, force_update=False, using=None,
update_fields=None): update_fields=None):
super(WorkSpecification, self).save(force_insert=force_insert, force_update=force_update, using=using, super(WorkSpecification, self).save(force_insert=force_insert, force_update=force_update, using=using,
update_fields=update_fields) update_fields=update_fields)
if self.async_task_result is None: if self.async_task_result is None:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment