diff --git a/apps/abs/models.py b/apps/abs/models.py index d656fa8..ecb8351 100644 --- a/apps/abs/models.py +++ b/apps/abs/models.py @@ -353,7 +353,6 @@ class ABSConfiguration(Configuration): def stop_device(self): - print("estoy en ABS models") self.device.status = 2 self.device.save() self.message = 'ABS has been stopped.' diff --git a/apps/main/management/commands/hello.py b/apps/main/management/commands/hello.py index d3be837..c0a002f 100644 --- a/apps/main/management/commands/hello.py +++ b/apps/main/management/commands/hello.py @@ -17,70 +17,55 @@ class Command(BaseCommand): manage.py restart_experiment """ def handle(self, *args, **options): - print("") + print("\n\n") + all_campaigns=Campaign.objects.all() campaigns = Campaign.objects.filter(start_date__lte=datetime.now(), end_date__gte=datetime.now()).order_by('-start_date') - if campaigns: - - for campaign in campaigns: - print(campaign.name) - print(campaign.start_date) - print(campaign.end_date) - print(campaign.experiments.all()[0].id) - print("STATUS: ",campaign.experiments.all()[0].status) + for campaign in all_campaigns: + if campaign.start_date datetime.now(): radar=campaign.get_experiments_by_radar(radar=None) - radar_id=radar[0]["id"] - print(radar_id) - - now = datetime.now() - if nowcampaign.start_date: - print("La campaƱa",campaign.name ,"se ejecuta!",flush=True) + for rad in radar: + # print("RADR", rad) + radar_id=rad["id"] + # print("RADR_",radar_id) radar_start_scheduler(campaign.id,radar_id) + print(campaign.name, "\t\t Campaign already running") - else: - copy_campaigns=Campaign.objects.all() - print("-------------Deteniendo procesos-------------") - for campaign in copy_campaigns: - print(campaign.name) - print(campaign.start_date) - print(campaign.end_date) - print("ID: ",campaign.experiments.all()[0].id) - print("STATUS: ",campaign.experiments.all()[0].status) - print("----,,,---") + else: radar=campaign.get_experiments_by_radar(radar=None) radar_id=radar[0]["id"] - if campaign.experiments.all()[0].status !=1: - print("Estoy en :",campaign.experiments.all()[0].status) - print("Con ID: ",campaign.experiments.all()[0].id) - print("\n\n") + print(campaign.name, "\t\t Stopping Campaign...") a=radar_stop_scheduler(campaign.id,radar_id,campaign.experiments.all()[0].id) - print("RETURN", a) - + print("New Status: ", a) + else: + print(campaign.name,"\t\t\t Campaign already stooped") def radar_start_scheduler(id_camp,id_radar): - print("-------------------") campaign = get_object_or_404(Campaign, pk=id_camp) experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments'] now = datetime.now() - + # print(campaign) + # print(experiments) for exp in experiments: exp = get_object_or_404(Experiment, pk=exp.id) - + # print("---------DEBUGG-------------") + # print(exp) if exp.status == 2: - print('Experiment {} already runnnig'.format(exp)) + print('\t\t\t {} \t\t Experiment already runnnig'.format(exp)) else: exp.status = exp.start() if exp.status == 0: - print('Experiment {} not start'.format(exp)) + print('\t\t\t {} \t\tExperiment not start'.format(exp)) if exp.status == 2: - print('Experiment {} started'.format(exp)) + print('\t\t\t {} \t\tExperiment started'.format(exp)) + if exp.status == 4: + print('\t\t\t {} \t\tExperiment with state uknown, please reset'.format(exp)) exp.save() def radar_stop_scheduler(id_camp,id_radar,id_experiment): - print("-------------------") ''' Stop experiments's devices DDS-JARS-RC-CGS-ABS @@ -92,8 +77,7 @@ def radar_stop_scheduler(id_camp,id_radar,id_experiment): confs = confs.exclude(device__device_type__name='cgs') try: for conf in confs: - print("Estoy en conf_scheduler") - print(conf) + # print(conf) conf.stop_device() exp.status= 1 except: