Commit 995e297b authored by Vasyl Bodnaruk's avatar Vasyl Bodnaruk

Add base view for new job

parent e6410551
......@@ -4,12 +4,14 @@ from .models import Spider, Job
class Service:
def update_jobs_status(self, jobs):
finished = jobs.get('finished')
if finished:
for i in finished:
Job.objects.get(job_id=i['id']).update(status='FIN', end_time=i['end_time'])
running = jobs.get('running')
if running:
for i in running:
Job.objects.get(job_id=i['id']).update(status='RUN')
try:
finished = jobs.get('finished')
if finished:
for i in finished:
Job.objects.get(job_id=i['id']).update(status='FIN', end_time=i['end_time'])
running = jobs.get('running')
if running:
for i in running:
Job.objects.get(job_id=i['id']).update(status='RUN')
except:
pass
from django.conf.urls import url
from .views import JobListView
from .views import JobListView, NewJobCreateView
urlpatterns = [
url('', JobListView.as_view(), name='job_list')
url('^new$', NewJobCreateView.as_view(), name='new_job'),
url('', JobListView.as_view(), name='job_list'),
]
\ No newline at end of file
from urllib.request import urlopen, Request
from django.shortcuts import render
from django.views.generic import ListView
from django.shortcuts import render, HttpResponseRedirect, reverse
from django.views.generic import ListView, CreateView
from scrapyd_api import ScrapydAPI
from .models import Spider, Job
......@@ -17,10 +16,6 @@ class JobListView(ListView):
super(JobListView, self).__init__()
def get(self, request, *args, **kwargs):
jobs = self.client.list_jobs('exa')
print(jobs)
self.service.update_jobs_status(jobs)
jobs = {
'deleted': Job.objects.deleted(),
'running': Job.objects.running(),
......@@ -37,4 +32,21 @@ class JobListView(ListView):
pass
if action == 'cancel':
pass
if action == 'update':
jobs = self.client.list_jobs('exa')
self.service.update_jobs_status(jobs)
if action == 'new':
return HttpResponseRedirect(reverse('new_job'))
return HttpResponseRedirect(reverse('job_list'))
class NewJobCreateView(CreateView):
template_name = 'new_job.html'
def get(self, request, *args, **kwargs):
return render(request, self.template_name)
def post(self, request, *args, **kwargs):
pass
{% extends 'base.html' %}
{% block content %}
{{ jobs }}
<form name="jobs" method="post">
{% csrf_token %}
<button name="action" value="new">New job</button>
<button name="action" value="update">Update</button>
<button name="action" value="cancel">Cancel</button>
</form>
{% endblock %}
\ No newline at end of file
{% extends 'base.html' %}
{% block content %}
new job
{% endblock %}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment